This is an automated email from the ASF dual-hosted git repository. wusheng pushed a commit to branch abandon in repository https://gitbox.apache.org/repos/asf/skywalking.git
The following commit(s) were added to refs/heads/abandon by this push: new 49e090debe Fix 49e090debe is described below commit 49e090debedcd907fb3d3c03ccd822a6e36bc57d Author: Wu Sheng <wu.sh...@foxmail.com> AuthorDate: Thu Nov 16 10:13:26 2023 +0800 Fix --- .../oap/server/library/datacarrier/consumer/ConsumerThread.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/oap-server/server-library/library-datacarrier-queue/src/main/java/org/apache/skywalking/oap/server/library/datacarrier/consumer/ConsumerThread.java b/oap-server/server-library/library-datacarrier-queue/src/main/java/org/apache/skywalking/oap/server/library/datacarrier/consumer/ConsumerThread.java index d5013f1c7b..30caa739b5 100644 --- a/oap-server/server-library/library-datacarrier-queue/src/main/java/org/apache/skywalking/oap/server/library/datacarrier/consumer/ConsumerThread.java +++ b/oap-server/server-library/library-datacarrier-queue/src/main/java/org/apache/skywalking/oap/server/library/datacarrier/consumer/ConsumerThread.java @@ -20,7 +20,6 @@ package org.apache.skywalking.oap.server.library.datacarrier.consumer; import java.util.ArrayList; import java.util.List; -import org.apache.skywalking.oap.server.library.datacarrier.buffer.Buffer; import org.apache.skywalking.oap.server.library.datacarrier.buffer.QueueBuffer; public class ConsumerThread<T> extends Thread { @@ -88,9 +87,6 @@ public class ConsumerThread<T> extends Thread { running = false; } - /** - * DataSource is a refer to {@link Buffer}. - */ class DataSource { private QueueBuffer<T> sourceBuffer;