未验证 提交 48479b74 编写于 作者: Z zcai2 提交者: GitHub

test: fix flaky test in comsumerTest (#5846)

Co-authored-by: NCai, Zhouxiang <zc31@illinois.edu>
Co-authored-by: NZhenxu Ke <kezhenxu94@apache.org>
上级 83258242
......@@ -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++) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册