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 d9519d696 [improve][connector] The Factory#factoryIdentifier must be
consistent with PluginIdentifierInterface#getPluginName (#3328)
add 5bfd50855 [feature][st-engine] Add jobHistory (#3191)
No new revisions were added by this update.
Summary of changes:
.../core/starter/command/AbstractCommandArgs.java | 21 +--
.../core/starter/utils/FileUtilsTest.java | 17 ++
.../core/starter/flink/args/FlinkCommandArgs.java | 16 +-
.../core/starter/spark/args/SparkCommandArgs.java | 15 ++
.../starter/seatunnel/args/ClientCommandArgs.java | 30 ++++
.../seatunnel/command/ClientExecuteCommand.java | 25 ++-
.../src/main}/resources/log4j.properties | 0
.../src/test/resources/junit-platform.properties | 5 +-
.../engine/e2e/ClusterFaultToleranceIT.java | 2 +-
.../src/test/resources/junit-platform.properties | 5 +-
.../src/test/resources/junit-platform.properties | 5 +-
.../seatunnel/engine/client/SeaTunnelClient.java | 16 ++
.../engine/client/SeaTunnelClientTest.java | 32 ++++
.../apache/seatunnel/engine/common/Constant.java | 2 +
...obCodec.java => SeaTunnelGetJobStateCodec.java} | 50 +++---
...Codec.java => SeaTunnelListJobStatusCodec.java} | 61 ++++---
.../SeaTunnelEngine.yaml | 38 +++++
.../engine/server/CoordinatorService.java | 23 ++-
.../engine/server/master/JobHistoryService.java | 178 +++++++++++++++++++++
...tusOperation.java => GetJobStateOperation.java} | 22 +--
...bOperation.java => ListJobStatusOperation.java} | 35 ++--
.../{CancelJobTask.java => GetJobStateTask.java} | 17 +-
.../{CancelJobTask.java => ListJobStatusTask.java} | 17 +-
.../task/SeaTunnelMessageTaskFactoryProvider.java | 6 +
.../engine/server/CoordinatorServiceTest.java | 4 +-
.../server/master/JobHistoryServiceTest.java | 104 ++++++++++++
.../src/test/resources}/fake_to_console.conf | 0
27 files changed, 616 insertions(+), 130 deletions(-)
copy
{seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-elasticsearch-flink-e2e/src/test
=> seatunnel-core/seatunnel-starter/src/main}/resources/log4j.properties (100%)
copy
seatunnel-engine/seatunnel-engine-common/src/main/resources/seatunnel.yaml =>
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/src/test/resources/junit-platform.properties
(85%)
copy
seatunnel-engine/seatunnel-engine-common/src/main/resources/seatunnel.yaml =>
seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/junit-platform.properties
(85%)
copy
seatunnel-engine/seatunnel-engine-common/src/main/resources/seatunnel.yaml =>
seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-jdbc-spark-e2e/src/test/resources/junit-platform.properties
(85%)
copy
seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/protocol/codec/{SeaTunnelCancelJobCodec.java
=> SeaTunnelGetJobStateCodec.java} (65%)
copy
seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/protocol/codec/{SeaTunnelCancelJobCodec.java
=> SeaTunnelListJobStatusCodec.java} (53%)
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/operation/{GetJobStatusOperation.java
=> GetJobStateOperation.java} (76%)
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/operation/{CancelJobOperation.java
=> ListJobStatusOperation.java} (53%)
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/{CancelJobTask.java
=> GetJobStateTask.java} (75%)
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/{CancelJobTask.java
=> ListJobStatusTask.java} (75%)
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/master/JobHistoryServiceTest.java
copy {seatunnel-examples/seatunnel-engine-examples/src/main/resources/examples
=>
seatunnel-engine/seatunnel-engine-server/src/test/resources}/fake_to_console.conf
(100%)
