Skip to content

Commit c024153

Browse files
committed
[fix] 解决合并代码的问题;
1 parent 268f399 commit c024153

1 file changed

Lines changed: 0 additions & 1 deletion

File tree

kafka-base/kafka-base-source/src/main/java/com/dtstack/flink/sql/source/kafka/table/KafkaSourceParser.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,6 @@ public AbstractTableInfo getTableInfo(String tableName, String fieldsInfo, Map<S
6969
);
7070

7171
kafkaSourceTableInfo.addKafkaParam(kafkaParams);
72-
parseFieldsInfo(fieldsInfo, kafkaSourceTableInfo);
7372
kafkaSourceTableInfo.check();
7473

7574
return kafkaSourceTableInfo;

0 commit comments

Comments
 (0)