This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 0278f0c143 [INLONG-9128][Sort] Fix the failed to init TubeMQ source
with InlongMsg type message (#9129)
add 2c8c787c89 [INLONG-9092][Manager] Tube supports inlong-msg format
(#9093)
No new revisions were added by this update.
Summary of changes:
.../manager/pojo/sort/node/provider/TubeMqProvider.java | 11 ++++++++---
.../manager/pojo/source/pulsar/PulsarSourceDTO.java | 3 +++
.../manager/pojo/source/pulsar/PulsarSourceRequest.java | 3 +++
.../inlong/manager/pojo/source/tubemq/TubeMQSource.java | 10 ++++++++--
.../manager/pojo/source/tubemq/TubeMQSourceDTO.java | 14 ++++++++------
.../manager/pojo/source/tubemq/TubeMQSourceRequest.java | 10 ++++++++--
.../service/source/tubemq/TubeMQSourceOperator.java | 9 +++++++++
.../manager/service/source/TubeMQSourceServiceTest.java | 2 +-
.../sort/protocol/node/extract/TubeMQExtractNode.java | 17 +++++------------
.../protocol/node/extract/TubeMQExtractNodeTest.java | 5 ++++-
.../inlong/sort/parser/TubeMQNodeSqlParseTest.java | 5 ++++-
11 files changed, 61 insertions(+), 28 deletions(-)
