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;
 

Reply via email to