This is an automated email from the ASF dual-hosted git repository.
yunqing pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 4f50594a6 [INLONG-6094][Kubernetes] Add liveness reliability for
modules (#6095)
add c164d788f [INLONG-6089][Manager][Sort] kafka extract node support raw
format and scan mode support timestamp (#6100)
No new revisions were added by this update.
Summary of changes:
.../manager/pojo/sort/util/ExtractNodeUtils.java | 10 ++++-
.../manager/pojo/source/kafka/KafkaOffset.java | 1 +
.../manager/pojo/source/kafka/KafkaSource.java | 3 ++
.../manager/pojo/source/kafka/KafkaSourceDTO.java | 4 ++
.../pojo/source/kafka/KafkaSourceRequest.java | 6 ++-
.../sort/protocol/constant/KafkaConstant.java | 2 +
.../sort/protocol/enums/KafkaScanStartupMode.java | 3 +-
.../protocol/node/extract/KafkaExtractNode.java | 22 ++++++++--
.../node/extract/KafkaExtractNodeTest.java | 36 ++++++++++++++-
.../sort/parser/DataTypeConvertSqlParseTest.java | 2 +-
.../sort/parser/DecimalFormatSqlParseTest.java | 2 +-
.../sort/parser/DistinctNodeSqlParseTest.java | 6 +--
.../inlong/sort/parser/FlinkSqlParserTest.java | 6 +--
.../sort/parser/FullOuterJoinSqlParseTest.java | 14 +++---
.../sort/parser/InnerJoinRelationSqlParseTest.java | 10 ++---
.../parser/IntervalJoinRelationSqlParseTest.java | 4 +-
.../inlong/sort/parser/KafkaSqlParseTest.java | 51 +++++++++++++++++++++-
.../sort/parser/LeftOuterJoinSqlParseTest.java | 10 ++---
.../inlong/sort/parser/MetaFieldSyncTest.java | 2 +-
.../MySqlTemporalJoinRelationSqlParseTest.java | 2 +-
.../sort/parser/RightOuterJoinSqlParseTest.java | 10 ++---
21 files changed, 164 insertions(+), 42 deletions(-)
