This is an automated email from the ASF dual-hosted git repository.
healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from db8a69dd6 [INLONG-6773][Manager] Fix the problem of sink cannot jump
from the configuration to successful configuration (#6774)
add 01de2893b [INLONG-6734][Manager] Support non-InlongMessage format of
Kafka and Pulsar (#6753)
No new revisions were added by this update.
Summary of changes:
.../manager/common/consts/InlongConstants.java | 2 +
.../manager/pojo/sort/util/ExtractNodeUtils.java | 109 ++++++++++-----------
.../manager/pojo/source/kafka/KafkaSource.java | 3 +
.../manager/pojo/source/pulsar/PulsarSource.java | 4 +
.../service/source/kafka/KafkaSourceOperator.java | 7 ++
.../source/pulsar/PulsarSourceOperator.java | 6 ++
6 files changed, 73 insertions(+), 58 deletions(-)
