This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 20900262ee [Test][E2E] Add regression coverage for task stuck in
CANCELING when worker crashes mid-cancel (#12030)
add 55cbbe7fed [Test][Zeta] Add E2E coverage for worker-restart restore
with missing coordinator checkpoint state (apache/seatunnel#11563) (#12183)
No new revisions were added by this update.
Summary of changes:
.../FinalCheckpointCloseHoldGate.java | 153 ++++++
.../FinalCheckpointCloseHoldSink.java | 39 +-
.../FinalCheckpointCloseHoldSinkFactory.java | 78 +++
.../FinalCheckpointCloseHoldSinkWriter.java | 123 +++++
...ClusterWorkerRestartAfterFinalCheckpointIT.java | 573 +++++++++++++++++++++
...er_batch_fake_to_close_hold_sink_template.conf} | 29 +-
6 files changed, 960 insertions(+), 35 deletions(-)
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/workerrestart/FinalCheckpointCloseHoldGate.java
copy
seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/sink/IoTDBSink.java
=>
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/workerrestart/FinalCheckpointCloseHoldSink.java
(52%)
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/workerrestart/FinalCheckpointCloseHoldSinkFactory.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/workerrestart/FinalCheckpointCloseHoldSinkWriter.java
create mode 100644
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/workerrestart/SplitClusterWorkerRestartAfterFinalCheckpointIT.java
copy
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/{allocate-strategy/allocate_strategy_tag2_with_system_load.conf
=> cluster_batch_fake_to_close_hold_sink_template.conf} (61%)
