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 3fcc7c377 [Hotfix][CI] Fix update modules check for CI (#3630)
add 4ae251e20 [Hotfix][ST Engine] fix get metrics bug (#3634)
No new revisions were added by this update.
Summary of changes:
.../api/common/metrics/RawJobMetrics.java | 3 +-
.../apache/seatunnel/api/env/EnvCommonOptions.java | 2 +-
.../engine/e2e/ClusterFaultToleranceIT.java | 1 +
...ava => ClusterFaultToleranceTwoPipelineIT.java} | 65 +++++++++++++---------
...h_fake_to_localfile_two_pipeline_template.conf} | 64 ++++++++++++++++++++-
.../engine/core/parse/JobConfigParser.java | 11 ++--
.../seatunnel/engine/server/master/JobMaster.java | 7 ++-
.../engine/server/operation/AsyncOperation.java | 4 +-
.../server/operation/CancelJobOperation.java | 4 +-
.../operation/CleanTaskGroupContextOperation.java | 41 --------------
.../server/operation/GetJobMetricsOperation.java | 6 +-
.../server/operation/GetJobStateOperation.java | 6 +-
.../server/operation/GetJobStatusOperation.java | 6 +-
.../server/operation/PrintMessageOperation.java | 6 +-
.../server/operation/SubmitJobOperation.java | 4 +-
.../operation/WaitForJobCompleteOperation.java | 4 +-
...ClientToServerOperationDataSerializerHook.java} | 18 +++---
.../serializable/TaskDataSerializerHook.java | 12 ++++
...on.java => CleanTaskGroupContextOperation.java} | 32 +++++------
.../operation/GetTaskGroupMetricsOperation.java | 35 +++++++++++-
.../services/com.hazelcast.DataSerializerHook | 2 +-
21 files changed, 204 insertions(+), 129 deletions(-)
copy
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/{ClusterFaultToleranceIT.java
=> ClusterFaultToleranceTwoPipelineIT.java} (89%)
copy
seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/resources/{cluster_batch_fake_to_localfile_template.conf
=> cluster_batch_fake_to_localfile_two_pipeline_template.conf} (59%)
delete mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/operation/CleanTaskGroupContextOperation.java
rename
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/{OperationDataSerializerHook.java
=> ClientToServerOperationDataSerializerHook.java} (86%)
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/{CancelTaskOperation.java
=> CleanTaskGroupContextOperation.java} (71%)
rename
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/{
=> task}/operation/GetTaskGroupMetricsOperation.java (68%)
