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%)
