You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by he...@apache.org on 2022/07/01 06:53:47 UTC

[inlong] branch master updated (bf8eb3a35 -> 218c920a2)

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 bf8eb3a35 [INLONG-4726][SortStandalone] Support ClickHouse sink (#4728)
     add 218c920a2 [INLONG-4715][Manager] Fix exception when no sink info is configured (#4760)

No new revisions were added by this update.

Summary of changes:
 .../inlong/manager/client/ut/Kafka2HiveTest.java   |  6 ++--
 .../manager/client/api/impl/InlongStreamImpl.java  |  2 +-
 .../common/pojo/stream/InlongStreamInfo.java       |  4 +--
 .../workflow/form/GroupResourceProcessForm.java    |  1 -
 .../plugin/listener/StartupSortListener.java       | 10 ++++++
 .../plugin/listener/StartupStreamListener.java     |  6 ++++
 .../service/core/impl/InlongStreamServiceImpl.java |  6 +++-
 .../service/sort/CreateSortConfigListenerV2.java   | 28 ++++++++++-----
 .../sort/CreateStreamSortConfigListener.java       | 29 ++++++++-------
 .../service/sort/light/LightGroupSortListener.java |  4 +--
 .../approve/GroupApproveProcessListener.java       |  2 +-
 .../workflow/core/impl/ProcessorExecutorImpl.java  | 41 ----------------------
 .../manager/workflow/definition/SkipResolver.java  | 38 --------------------
 .../workflow/definition/SkippableElement.java      | 35 ------------------
 .../manager/workflow/definition/WorkflowTask.java  | 12 +------
 .../workflow/processor/AbstractTaskProcessor.java  | 38 +-------------------
 .../processor/SkipableElementProcessor.java        | 36 -------------------
 17 files changed, 68 insertions(+), 230 deletions(-)
 delete mode 100644 inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/definition/SkipResolver.java
 delete mode 100644 inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/definition/SkippableElement.java
 delete mode 100644 inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/processor/SkipableElementProcessor.java