This is an automated email from the ASF dual-hosted git repository.
fanjia pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from e3f8009564 [CI] Fix CI unstable problem (#5896)
add 83ec866784 [Fix][Zeta] Fix CheckpointCoordinator report NPE when ack
not existed pending checkpoint (#5909)
No new revisions were added by this update.
Summary of changes:
seatunnel-engine/seatunnel-engine-server/pom.xml | 6 +++
.../server/checkpoint/CheckpointCoordinator.java | 4 ++
.../checkpoint/CheckpointCoordinatorTest.java | 63 ++++++++++++++++++++++
3 files changed, 73 insertions(+)
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointCoordinatorTest.java
