[FLINK-17739][network][tests] Fix unstable ResultPartitionTest#testIn…

…itializeMoreStateThanBuffer
spotify · May 16, 2020 · 7796f6e · 7796f6e
1 parent dc3a498
commit 7796f6e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...time/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionTest.java b/...time/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionTest.java
@@ -61,6 +61,7 @@
 import static org.hamcrest.Matchers.contains;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNull;
 import static org.junit.Assert.assertTrue;
 import static org.mockito.Matchers.eq;
 import static org.mockito.Mockito.mock;
@@ -509,6 +510,7 @@ public void testInitializeMoreStateThanBuffer() throws Exception {
  Thread.sleep(5);
  }
  }
+ assertNull(view.getNextBuffer());
  }
  return null;
  };