From 48479b74df22a71e7a894e600a94df593a583187 Mon Sep 17 00:00:00 2001
From: zcai2 <zcai2@gmu.edu>
Date: Mon, 16 Nov 2020 02:19:47 -0600
Subject: [PATCH] test: fix flaky test in comsumerTest (#5846)

Co-authored-by: Cai, Zhouxiang <zc31@illinois.edu>
Co-authored-by: Zhenxu Ke <kezhenxu94@apache.org>
---
 .../apm/commons/datacarrier/consumer/ConsumerTest.java          | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/apm-commons/apm-datacarrier/src/test/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumerTest.java b/apm-commons/apm-datacarrier/src/test/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumerTest.java
index e92c35e42..6da897d4f 100644
--- a/apm-commons/apm-datacarrier/src/test/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumerTest.java
+++ b/apm-commons/apm-datacarrier/src/test/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumerTest.java
@@ -35,6 +35,7 @@ public class ConsumerTest {
 
     @Test
     public void testConsumerLessThanChannel() throws IllegalAccessException {
+
         final DataCarrier<SampleData> carrier = new DataCarrier<SampleData>(2, 100);
 
         for (int i = 0; i < 100; i++) {
@@ -56,6 +57,7 @@ public class ConsumerTest {
 
     @Test
     public void testConsumerMoreThanChannel() throws IllegalAccessException, InterruptedException {
+        BUFFER.drainTo(new ArrayList<SampleData>());
         final DataCarrier<SampleData> carrier = new DataCarrier<SampleData>(2, 100);
 
         for (int i = 0; i < 200; i++) {