This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit e5a6a9410148ef064b4f78ee4020fb7b451f7030 Author: Stephan Ewen <[email protected]> AuthorDate: Thu Apr 25 12:43:30 2019 +0200 [hotfix] [tests] Remove redundant test assertions These seem to be remainders of a copy/paste error. --- .../flink/runtime/io/network/partition/SubpartitionTestBase.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SubpartitionTestBase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SubpartitionTestBase.java index 9f5e6d0..e4006be 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SubpartitionTestBase.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SubpartitionTestBase.java @@ -60,9 +60,6 @@ public abstract class SubpartitionTestBase extends TestLogger { try { subpartition.finish(); assertEquals(1, subpartition.getTotalNumberOfBuffers()); - assertEquals(0, subpartition.getTotalNumberOfBytes()); // only updated after consuming the buffers - - assertEquals(1, subpartition.getTotalNumberOfBuffers()); assertEquals(0, subpartition.getBuffersInBacklog()); assertEquals(0, subpartition.getTotalNumberOfBytes()); // only updated after consuming the buffers @@ -85,8 +82,6 @@ public abstract class SubpartitionTestBase extends TestLogger { try { subpartition.release(); - assertEquals(0, subpartition.getTotalNumberOfBuffers()); - assertEquals(0, subpartition.getTotalNumberOfBytes()); assertEquals(0, subpartition.getTotalNumberOfBuffers()); assertEquals(0, subpartition.getBuffersInBacklog());
