This is an automated email from the ASF dual-hosted git repository.
zirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 785665410 [INLONG-5092][SDK] Change Kafka default partition assignment
strategy to RangeAssignor (#5093)
add d14ad3993 [INLONG-5074][Sort] KafkaExtractNode support more
StartupMode (#5079)
No new revisions were added by this update.
Summary of changes:
.../common/pojo/source/kafka/KafkaOffset.java | 2 +
.../common/pojo/source/kafka/KafkaSource.java | 7 +-
.../common/pojo/source/kafka/KafkaSourceDTO.java | 7 +-
.../pojo/source/kafka/KafkaSourceRequest.java | 5 +-
.../service/sort/util/ExtractNodeUtils.java | 8 +-
.../sort/protocol/constant/KafkaConstant.java | 2 +
.../sort/protocol/enums/KafkaScanStartupMode.java | 3 +-
.../protocol/node/extract/KafkaExtractNode.java | 12 ++-
.../node/extract/KafkaExtractNodeTest.java | 2 +-
.../sort/parser/DataTypeConvertSqlParseTest.java | 2 +-
.../sort/parser/DecimalFormatSqlParseTest.java | 2 +-
.../sort/parser/DistinctNodeSqlParseTest.java | 6 +-
.../inlong/sort/parser/FlinkSqlParserTest.java | 2 +-
.../sort/parser/FullOuterJoinSqlParseTest.java | 6 +-
.../sort/parser/InnerJoinRelationSqlParseTest.java | 6 +-
...oadSqlParseTest.java => KafkaSqlParseTest.java} | 105 ++++++++++-----------
.../sort/parser/LeftOuterJoinSqlParseTest.java | 6 +-
.../inlong/sort/parser/MetaFieldSyncTest.java | 2 +-
.../sort/parser/RightOuterJoinSqlParseTest.java | 6 +-
19 files changed, 106 insertions(+), 85 deletions(-)
copy
inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/{MySqlLoadSqlParseTest.java
=> KafkaSqlParseTest.java} (71%)
