This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch reduce-submit-self in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 5813c76c3d0c905f188c2c7a77aebd6e4d7e2ba6 Author: Steve Yurong Su <[email protected]> AuthorDate: Wed May 31 16:05:00 2023 +0800 ArrayBlockingQueue --- .../db/pipe/task/queue/ListenableBoundedBlockingPendingQueue.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/task/queue/ListenableBoundedBlockingPendingQueue.java b/server/src/main/java/org/apache/iotdb/db/pipe/task/queue/ListenableBoundedBlockingPendingQueue.java index da91cc4187b..1614f738254 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/task/queue/ListenableBoundedBlockingPendingQueue.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/task/queue/ListenableBoundedBlockingPendingQueue.java @@ -21,12 +21,12 @@ package org.apache.iotdb.db.pipe.task.queue; import org.apache.iotdb.pipe.api.event.Event; -import org.eclipse.jetty.util.BlockingArrayQueue; +import java.util.concurrent.ArrayBlockingQueue; public class ListenableBoundedBlockingPendingQueue<E extends Event> extends ListenableBlockingPendingQueue<E> { public ListenableBoundedBlockingPendingQueue(int pendingQueueSize) { - super(new BlockingArrayQueue<>(pendingQueueSize)); + super(new ArrayBlockingQueue<>(pendingQueueSize)); } }
