Skip to content

Commit 542de96

Browse files
committed
change to a better class
Signed-off-by: xinyual <xinyual@amazon.com>
1 parent f53a656 commit 542de96

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

plugin/src/main/java/org/opensearch/ml/action/models/DeleteModelTransportAction.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import java.util.Locale;
2525
import java.util.Map;
2626
import java.util.Objects;
27+
import java.util.concurrent.ConcurrentLinkedQueue;
2728
import java.util.concurrent.CopyOnWriteArrayList;
2829
import java.util.concurrent.CountDownLatch;
2930
import java.util.concurrent.atomic.AtomicBoolean;
@@ -354,7 +355,7 @@ private void checkSearchPipelineBeforeDeleteModel(String modelId, ActionListener
354355
private void checkDownstreamTaskBeforeDeleteModel(String modelId, Boolean isHidden, ActionListener<DeleteResponse> actionListener) {
355356
CountDownLatch countDownLatch = new CountDownLatch(3);
356357
AtomicBoolean noneBlocked = new AtomicBoolean(true);
357-
CopyOnWriteArrayList<String> errorMessages = new CopyOnWriteArrayList<>();
358+
ConcurrentLinkedQueue<String> errorMessages = new ConcurrentLinkedQueue<>();
358359
ActionListener<Boolean> countDownActionListener = ActionListener.wrap(b -> {
359360
countDownLatch.countDown();
360361
noneBlocked.compareAndSet(true, b);

0 commit comments

Comments
 (0)