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

Posted to commits@seatunnel.apache.org by ty...@apache.org on 2023/03/14 02:52:50 UTC

[incubator-seatunnel] branch dev updated (cf0abb9b4 -> cf55b070b)

This is an automated email from the ASF dual-hosted git repository.

tyrantlucifer pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


    from cf0abb9b4 [Improve][Core] Unified the checkpoint setting key of Flink (#4296)
     add cf55b070b [Hotfix][Zeta] Fix TaskExecutionService Deploy Failed The Job Can't Stop (#4265)

No new revisions were added by this update.

Summary of changes:
 config/seatunnel-env.sh                            |  3 -
 config/seatunnel.yaml                              |  4 +-
 .../seatunnel/api/table/factory/FactoryUtil.java   |  3 +-
 .../seatunnel/common/utils/ExceptionUtils.java     |  3 +
 .../kafka/source/KafkaSourceSplitEnumerator.java   | 14 ++--
 .../common/config/server/ServerConfigOptions.java  |  2 +-
 .../src/main/resources/seatunnel.yaml              |  2 +-
 .../engine/server/TaskExecutionService.java        | 80 +++++++++-------------
 .../engine/server/dag/physical/PhysicalVertex.java | 60 ++++++++--------
 .../engine/server/dag/physical/SubPlan.java        |  7 +-
 .../{TaskGroup.java => TaskDeployState.java}       | 23 ++++---
 .../server/execution/TaskExecutionState.java       | 18 ++++-
 .../server/scheduler/PipelineBaseScheduler.java    | 19 ++++-
 .../server/service/slot/DefaultSlotService.java    |  2 +-
 .../server/task/operation/DeployTaskOperation.java | 17 +++--
 .../engine/server/TaskExecutionServiceTest.java    | 21 +++---
 16 files changed, 151 insertions(+), 127 deletions(-)
 copy seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/execution/{TaskGroup.java => TaskDeployState.java} (66%)