[incubator-inlong] branch master updated (04d7a5f1c -> 831a0f447)

[he...@apache.org]

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/incubator-inlong.git


    from 04d7a5f1c [INLONG-4408][Manager][Sort] Add Iceberg sink load node (#4409)
     add 831a0f447 [INLONG-4476][Sort][Manager] Remove zk and related classes (#4480)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/inlong/common/enums/MetaField.java  |  92 ++++++
 .../src/main/assemblies/sort-connectors.xml        |  16 +
 .../service/sink/hive/HiveSinkOperation.java       |   8 +-
 .../service/sort/CreateSortConfigListener.java     |  18 +-
 .../service/sort/PushSortConfigListener.java       |  10 +-
 .../manager/service/sort/util/DataFlowUtils.java   |  26 +-
 .../manager/service/sort/util/FieldInfoUtils.java  |  18 +-
 .../manager/service/sort/util/LoadNodeUtils.java   |  39 ++-
 .../service/sort/util/SerializationUtils.java      | 175 -----------
 .../manager/service/sort/util/SinkInfoUtils.java   |  80 ++---
 .../manager/service/sort/util/SourceInfoUtils.java |  41 +--
 inlong-sort/sort-api/pom.xml                       |   8 +-
 .../main/java/org/apache/inlong/sort/ZkTools.java  | 149 ----------
 inlong-sort/sort-common/pom.xml                    |  10 +-
 .../apache/inlong/sort/protocol/DataFlowInfo.java  | 123 --------
 .../inlong/sort/protocol/DataFlowStorageInfo.java  |  79 -----
 .../apache/inlong/sort/protocol/MetaFieldInfo.java |  71 +----
 .../sort/protocol/sink/ClickHouseSinkInfo.java     | 160 ----------
 .../inlong/sort/protocol/sink/DorisSinkInfo.java   | 107 -------
 .../sort/protocol/sink/ElasticsearchSinkInfo.java  | 115 --------
 .../inlong/sort/protocol/sink/HbaseSinkInfo.java   | 110 -------
 .../inlong/sort/protocol/sink/HiveSinkInfo.java    | 324 ---------------------
 .../inlong/sort/protocol/sink/IcebergSinkInfo.java |  45 ---
 .../inlong/sort/protocol/sink/KafkaSinkInfo.java   |  94 ------
 .../apache/inlong/sort/protocol/sink/SinkInfo.java |  79 -----
 .../sort/protocol/source/PulsarSourceInfo.java     | 103 -------
 .../inlong/sort/protocol/source/SourceInfo.java    |  67 -----
 .../sort/protocol/source/TDMQPulsarSourceInfo.java |  93 ------
 .../sort/protocol/source/TubeSourceInfo.java       |  73 -----
 .../protocol/transformation/FieldMappingRule.java  | 114 --------
 .../transformation/TransformationInfo.java         |  59 ----
 .../transformation/TransformationRule.java         |  32 --
 .../inlong/sort/util/DefaultValueStrategy.java     |  82 ------
 .../apache/inlong/sort/util/ZooKeeperUtils.java    | 265 -----------------
 .../sort/protocol/DeserializationInfoTest.java     |  55 ----
 .../inlong/sort/protocol/MetaFieldInfoTest.java    |   3 +-
 .../sort/protocol/kafka/KafkaSinkInfoTest.java     |  40 ---
 .../sort/protocol/source/PulsarSourceInfoTest.java |  67 -----
 .../transformation/FieldMappingRuleTest.java       |  39 ---
 .../transformation/TransformationInfoTest.java     |  45 ---
 inlong-sort/sort-connectors/mysql-cdc/pom.xml      |   5 +
 .../inlong/sort/parser/impl/FlinkSqlParser.java    |  15 +-
 .../apache/inlong/sort/parser/AllMigrateTest.java  |   3 +-
 .../sort/parser/DistinctNodeSqlParseTest.java      |   5 +-
 .../inlong/sort/parser/MetaFieldSyncTest.java      |  89 +++---
 licenses/inlong-manager/LICENSE                    |   3 -
 licenses/inlong-manager/NOTICE                     |  39 ---
 licenses/inlong-sort/LICENSE                       |   3 -
 licenses/inlong-sort/NOTICE                        |  39 ---
 49 files changed, 277 insertions(+), 3058 deletions(-)
 create mode 100644 inlong-common/src/main/java/org/apache/inlong/common/enums/MetaField.java
 delete mode 100644 inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sort/util/SerializationUtils.java
 delete mode 100644 inlong-sort/sort-api/src/main/java/org/apache/inlong/sort/ZkTools.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/DataFlowInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/DataFlowStorageInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/sink/ClickHouseSinkInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/sink/DorisSinkInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/sink/ElasticsearchSinkInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/sink/HbaseSinkInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/sink/HiveSinkInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/sink/IcebergSinkInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/sink/KafkaSinkInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/sink/SinkInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/source/PulsarSourceInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/source/SourceInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/source/TDMQPulsarSourceInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/source/TubeSourceInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/transformation/FieldMappingRule.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/transformation/TransformationInfo.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/transformation/TransformationRule.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/DefaultValueStrategy.java
 delete mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/ZooKeeperUtils.java
 delete mode 100644 inlong-sort/sort-common/src/test/java/org/apache/inlong/sort/protocol/DeserializationInfoTest.java
 delete mode 100644 inlong-sort/sort-common/src/test/java/org/apache/inlong/sort/protocol/kafka/KafkaSinkInfoTest.java
 delete mode 100644 inlong-sort/sort-common/src/test/java/org/apache/inlong/sort/protocol/source/PulsarSourceInfoTest.java
 delete mode 100644 inlong-sort/sort-common/src/test/java/org/apache/inlong/sort/protocol/transformation/FieldMappingRuleTest.java
 delete mode 100644 inlong-sort/sort-common/src/test/java/org/apache/inlong/sort/protocol/transformation/TransformationInfoTest.java