This is an automated email from the ASF dual-hosted git repository. gaojun2048 pushed a commit to branch apache_240710_improve_event in repository https://gitbox.apache.org/repos/asf/seatunnel.git
commit f80834bcabfa551daec446758f144e1c92676025 Author: Eric <[email protected]> AuthorDate: Wed Jul 10 13:40:44 2024 +0800 Add EventService --- .../org/apache/seatunnel/engine/server/TaskExecutionService.java | 1 - .../org/apache/seatunnel/engine/server/master/JobMaster.java | 9 --------- 2 files changed, 10 deletions(-) diff --git a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java index beb51ac082..b6bbc6a35b 100644 --- a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java +++ b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java @@ -51,7 +51,6 @@ import org.apache.seatunnel.engine.server.task.operation.NotifyTaskStatusOperati import org.apache.commons.collections4.CollectionUtils; import com.google.common.collect.Lists; -import com.google.common.util.concurrent.ThreadFactoryBuilder; import com.hazelcast.instance.impl.NodeState; import com.hazelcast.internal.metrics.DynamicMetricsProvider; import com.hazelcast.internal.metrics.MetricDescriptor; diff --git a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java index 4c68d29cc4..29d8611f13 100644 --- a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java +++ b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java @@ -384,15 +384,6 @@ public class JobMaster { } } - private void reportEventOfSaveMode( - long jobId, TablePath tablePath, int indexOfCount, long startTime, long finishedTime) { - seaTunnelServer - .getEventService() - .reportEvent( - new SaveModeFinishedEvent( - jobId, tablePath, indexOfCount, startTime, finishedTime)); - } - public void handleCheckpointError(long pipelineId, boolean neverRestore) { if (neverRestore) { this.neverNeedRestore();
