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/incubator-inlong.git.
from 4ad1625 [INLONG-2545][Agent] agent pull task (binlog,file) from
manager (#2547)
add 8e234b5 [INLONG-2636] Enable sort config generate when zookeeper is
disabled; (#2657)
No new revisions were added by this update.
Summary of changes:
.../client/api/util/InlongGroupTransfer.java | 2 +-
...keFieldResponse.java => SinkFieldResponse.java} | 2 +-
.../manager/common/pojo/sink/SinkResponse.java | 2 +-
.../sink/ck/ClickHouseStreamSinkOperation.java | 6 +-
.../service/sink/hive/HiveStreamSinkOperation.java | 6 +-
.../sink/iceberg/IcebergStreamSinkOperation.java | 6 +-
.../thirdparty/sort/CreateSortConfigListener.java | 198 ++++++++++++
.../sort/PushHiveConfigTaskListener.java | 357 ---------------------
.../thirdparty/sort/PushSortConfigListener.java | 212 ++++++++++++
.../service/thirdparty/sort/SinkInfoUtils.java | 153 +++++++++
.../service/thirdparty/sort/SourceInfoUtils.java | 68 ++++
...tSelector.java => ZkDisabledEventSelector.java} | 19 +-
...ntSelector.java => ZkEnabledEventSelector.java} | 2 +-
.../workflow/ServiceTaskListenerFactory.java | 18 +-
.../group/SuspendGroupWorkflowDefinition.java | 2 +-
.../listener/GroupCompleteProcessListener.java | 6 +-
.../stream/CreateStreamWorkflowDefinition.java | 6 +-
.../thirdparty/sort/DisableZkForSortTest.java | 171 ++++++++++
.../service/workflow/WorkflowServiceImplTest.java | 45 +--
.../main/resources/sql/apache_inlong_manager.sql | 2 +-
.../manager-web/sql/apache_inlong_manager.sql | 2 +-
21 files changed, 874 insertions(+), 411 deletions(-)
rename
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/{SinkeFieldResponse.java
=> SinkFieldResponse.java} (97%)
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdparty/sort/CreateSortConfigListener.java
delete mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdparty/sort/PushHiveConfigTaskListener.java
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdparty/sort/PushSortConfigListener.java
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdparty/sort/SinkInfoUtils.java
create mode 100644
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdparty/sort/SourceInfoUtils.java
copy
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdparty/sort/{ZkSortEventSelector.java
=> ZkDisabledEventSelector.java} (65%)
rename
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/thirdparty/sort/{ZkSortEventSelector.java
=> ZkEnabledEventSelector.java} (96%)
create mode 100644
inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/thirdparty/sort/DisableZkForSortTest.java
