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

Posted to commits@seatunnel.apache.org by ga...@apache.org on 2022/10/20 10:59:48 UTC

[incubator-seatunnel] branch dev updated (a8738ef3c -> 8a9af87c2)

This is an automated email from the ASF dual-hosted git repository.

gaojun2048 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


    from a8738ef3c [Improve][Connector-V2][Hive] Hive Sink Support msck partitions (#3133)
     add 8a9af87c2 [improve][engine] PipelineState is renamed PipelineStatus (#3130)

No new revisions were added by this update.

Summary of changes:
 .../core/checkpoint/CheckpointIDCounter.java       |  4 +-
 .../{PipelineState.java => PipelineStatus.java}    |  2 +-
 .../engine/server/CoordinatorService.java          |  3 +-
 .../server/checkpoint/CheckpointManager.java       |  5 +-
 .../server/checkpoint/IMapCheckpointIDCounter.java |  4 +-
 .../checkpoint/StandaloneCheckpointIDCounter.java  |  4 +-
 .../engine/server/dag/physical/PhysicalPlan.java   |  8 ++--
 .../server/dag/physical/PhysicalPlanGenerator.java |  6 +--
 .../engine/server/dag/physical/SubPlan.java        | 54 +++++++++++-----------
 .../server/scheduler/PipelineBaseScheduler.java    | 22 ++++-----
 .../server/checkpoint/CheckpointManagerTest.java   |  3 +-
 .../engine/server/master/JobMasterTest.java        |  3 +-
 12 files changed, 61 insertions(+), 57 deletions(-)
 rename seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/job/{PipelineState.java => PipelineStatus.java} (98%)