This is an automated email from the ASF dual-hosted git repository.
nzw921rx pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from f7a575432f [Fix][Connector-V2] Keep TIMESTAMP microseconds in the
Lance sink (#13043)
add b274eb1f28 [Fix][Zeta] Preserve idle reader state after master switch
(#12042)
No new revisions were added by this update.
Summary of changes:
.../fault-tolerance/checkpoint-mechanism.md | 16 ++
.../fault-tolerance/checkpoint-mechanism.md | 13 ++
.../e2e/CheckpointCoordinatorFailoverIT.java | 166 ++++++++++++++
...o_localfile_idle_reader_failover_template.conf} | 25 +--
.../server/checkpoint/CheckpointCoordinator.java | 23 ++
.../engine/server/dag/physical/PhysicalVertex.java | 27 +++
.../engine/server/dag/physical/SubPlan.java | 56 +++--
.../engine/server/task/SourceSeaTunnelTask.java | 12 +
.../checkpoint/CheckpointCoordinatorTest.java | 116 +++++++++-
.../server/dag/physical/PhysicalVertexTest.java | 202 +++++++++++++++++
.../engine/server/dag/physical/SubPlanTest.java | 242 +++++++++++++++++++++
11 files changed, 856 insertions(+), 42 deletions(-)
copy
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/{stream_fake_to_localfile_savepoint_precondition_template.conf
=> stream_fake_to_localfile_idle_reader_failover_template.conf} (78%)
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalVertexTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/dag/physical/SubPlanTest.java
