You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2019/05/10 23:34:11 UTC
[flink] 12/14: [hotfix] [tests] Remove redundant test assertions
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 <se...@apache.org>
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());