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

Posted to commits@seatunnel.apache.org by fa...@apache.org on 2022/10/24 01:55:35 UTC

[incubator-seatunnel] branch dev updated (8cd0e5108 -> bc852a4df)

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/incubator-seatunnel.git


    from 8cd0e5108 [Improve][Doc][OSSFile] Updated description tip (#3163)
     add bc852a4df [Bug]add 3node worker done test and fix some bug (#3115)

No new revisions were added by this update.

Summary of changes:
 .../seatunnel/file/sink/BaseFileSinkWriter.java    |   5 +-
 .../sink/commit/FileSinkAggregatedCommitter.java   |   1 +
 .../seatunnel/file/sink/util/FileSystemUtils.java  |  12 +-
 .../file/sink/writer/AbstractWriteStrategy.java    |  13 +-
 .../seatunnel/file/sink/writer/WriteStrategy.java  |   2 +
 .../engine/e2e/ClusterFaultToleranceIT.java        | 558 ++++++++++++++++++---
 .../cluster_batch_fake_to_localfile_template.conf  |   4 +-
 .../seatunnel/engine/client/SeaTunnelClient.java   |   6 +
 .../engine/client/SeaTunnelHazelcastClient.java    |   6 +
 .../common/config/server/ServerConfigOptions.java  |   2 +-
 .../src/main/resources/hazelcast.yaml              |  11 +-
 .../engine/server/CoordinatorService.java          |   8 +-
 .../seatunnel/engine/server/SeaTunnelServer.java   |   3 +
 .../engine/server/SeaTunnelServerStarter.java      |   4 +-
 .../engine/server/TaskExecutionService.java        |  27 +-
 .../server/checkpoint/CheckpointCoordinator.java   |  52 +-
 .../server/checkpoint/CheckpointFailureReason.java |   2 +-
 .../server/checkpoint/CheckpointManager.java       |  45 +-
 .../server/checkpoint/IMapCheckpointIDCounter.java |   8 +-
 .../engine/server/dag/physical/PhysicalPlan.java   |  17 +
 .../engine/server/dag/physical/PhysicalVertex.java |   3 +-
 .../engine/server/dag/physical/SubPlan.java        |   2 +
 .../seatunnel/engine/server/master/JobMaster.java  |  14 +
 .../engine/server/CoordinatorServiceTest.java      |   7 +-
 .../server/checkpoint/CheckpointManagerTest.java   |   5 +-
 25 files changed, 662 insertions(+), 155 deletions(-)