Skip to content

Commit dc2873b

Browse files
committed
[opt-1422][file] 调整 file 判断 fromLine 的逻辑
1 parent bdd2fd8 commit dc2873b

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

file/file-source/src/main/java/com/dtstack/flink/sql/source/file/FileSource.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -210,7 +210,7 @@ public void run(SourceContext<Row> ctx) throws Exception {
210210
} else {
211211
numInRecord.inc();
212212

213-
if (numInRecord.getCount() <= fromLine) {
213+
if (numInRecord.getCount() < fromLine) {
214214
continue;
215215
}
216216

file/file-source/src/main/java/com/dtstack/flink/sql/source/file/table/FileSourceParser.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ private FileSourceTableInfo switchTableType(String tableName,
7373
tableInfo.setEscapeCharacter(escapeChar);
7474
}
7575

76-
tableInfo.setFromLine(MathUtil.getIntegerVal(props.getOrDefault(FileSourceConstant.FROM_LINE_KEY, 1)));
76+
tableInfo.setFromLine(MathUtil.getIntegerVal(props.getOrDefault(FileSourceConstant.FROM_LINE_KEY.toLowerCase(), 1)));
7777
tableInfo.buildDeserializationSchema();
7878
return tableInfo;
7979
}

0 commit comments

Comments
 (0)