Fixed buffer lost. (#3118)

8d705339 · 彭勇升 pengys · wu-sheng · ed507b78 · 8d705339
隐藏空白更改
内联并排

Showing with 4 addition and 0 deletion

oap-server/server-library/library-buffer/src/main/java/org/apache/skywalking/oap/server/library/buffer/DataStreamReader.java ...kywalking/oap/server/library/buffer/DataStreamReader.java +4 -0

未找到文件。
--- a/oap-server/server-library/library-buffer/src/main/java/org/apache/skywalking/oap/server/library/buffer/DataStreamReader.java
+++ b/oap-server/server-library/library-buffer/src/main/java/org/apache/skywalking/oap/server/library/buffer/DataStreamReader.java
@@ -145,6 +145,10 @@ public class DataStreamReader<MESSAGE_TYPE extends GeneratedMessageV3> {
                    }
                }
            }
+
+            if (bufferDataCollection.size() > 0) {
+                reCall();
+            }
        } catch (IOException e) {
            logger.error(e.getMessage(), e);
        }