From 7c6eebf98cdf4fcd727a7ff15962b918f7bf7aaf Mon Sep 17 00:00:00 2001 From: vinoyang Date: Sat, 10 Jul 2021 14:35:40 +0800 Subject: [PATCH] [MINOR] Fix some wrong assert reasons (#3248) --- .../java/org/apache/hudi/sink/TestWriteCopyOnWrite.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteCopyOnWrite.java b/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteCopyOnWrite.java index b3338a908..e145076bc 100644 --- a/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteCopyOnWrite.java +++ b/hudi-flink/src/test/java/org/apache/hudi/sink/TestWriteCopyOnWrite.java @@ -399,7 +399,7 @@ public class TestWriteCopyOnWrite { Map> dataBuffer = funcWrapper.getDataBuffer(); assertThat("Should have 1 data bucket", dataBuffer.size(), is(1)); - assertThat("3 records expect to flush out as a mini-batch", + assertThat("2 records expect to flush out as a mini-batch", dataBuffer.values().stream().findFirst().map(List::size).orElse(-1), is(2)); @@ -461,7 +461,7 @@ public class TestWriteCopyOnWrite { Map> dataBuffer = funcWrapper.getDataBuffer(); assertThat("Should have 1 data bucket", dataBuffer.size(), is(1)); - assertThat("3 records expect to flush out as a mini-batch", + assertThat("2 records expect to flush out as a mini-batch", dataBuffer.values().stream().findFirst().map(List::size).orElse(-1), is(2)); @@ -525,7 +525,7 @@ public class TestWriteCopyOnWrite { Map> dataBuffer = funcWrapper.getDataBuffer(); assertThat("Should have 1 data bucket", dataBuffer.size(), is(1)); - assertThat("3 records expect to flush out as a mini-batch", + assertThat("2 records expect to flush out as a mini-batch", dataBuffer.values().stream().findFirst().map(List::size).orElse(-1), is(2));