[seatunnel] branch dev updated: [Improve][Zeta] Improve dependency packages (#5624)

[wenjun]

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

wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 0c9dc19aa1 [Improve][Zeta] Improve dependency packages (#5624)
0c9dc19aa1 is described below

commit 0c9dc19aa15b7c6b2676317890fd34b33a11c479
Author: hailin0 <wanghai...@apache.org>
AuthorDate: Mon Oct 16 11:02:06 2023 +0800

    [Improve][Zeta] Improve dependency packages (#5624)
---
 .../apache/seatunnel/engine/server/checkpoint/CheckpointPlan.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointPlan.java
 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointPlan.java
index 80b04df54a..dfab876f03 100644
--- 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointPlan.java
+++ 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointPlan.java
@@ -20,7 +20,6 @@ package org.apache.seatunnel.engine.server.checkpoint;
 import org.apache.seatunnel.engine.server.execution.TaskLocation;
 
 import com.hazelcast.jet.datamodel.Tuple2;
-import com.sun.jersey.client.impl.CopyOnWriteHashMap;
 import lombok.AccessLevel;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
@@ -28,6 +27,7 @@ import lombok.Getter;
 
 import java.util.Map;
 import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.CopyOnWriteArraySet;
 
 /** checkpoint plan info */
@@ -63,10 +63,10 @@ public class CheckpointPlan {
     public static final class Builder {
         private final Set<TaskLocation> pipelineSubtasks = new 
CopyOnWriteArraySet<>();
         private final Set<TaskLocation> startingSubtasks = new 
CopyOnWriteArraySet<>();
-        private final Map<ActionStateKey, Integer> pipelineActions = new 
CopyOnWriteHashMap<>();
+        private final Map<ActionStateKey, Integer> pipelineActions = new 
ConcurrentHashMap<>();
 
         private final Map<TaskLocation, Set<Tuple2<ActionStateKey, Integer>>> 
subtaskActions =
-                new CopyOnWriteHashMap<>();
+                new ConcurrentHashMap<>();
 
         private Builder() {}