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 9b6dd65d4d [INLONG-8157][CI] Support execute Maven commands in any
submodule (#8158)
add 3062a3b446 [INLONG-8143][Sort] Kafka support DDL (#8144)
No new revisions were added by this update.
Summary of changes:
.../sort-flink-v1.13/sort-connectors/kafka/pom.xml | 18 +++++++++
.../kafka/DynamicKafkaSerializationSchema.java | 45 +++++++++++++++++++++-
.../apache/inlong/sort/kafka/KafkaDynamicSink.java | 13 +++++--
.../sort/kafka/table/KafkaDynamicTableFactory.java | 23 +++++++++--
.../table/UpsertKafkaDynamicTableFactory.java | 13 ++++++-
5 files changed, 104 insertions(+), 8 deletions(-)