Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5802#discussion_r178707684
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/writer/RecordWriterTest.java
---
@@ -309,8 +309,6 @@ public void testBroadcastEventBufferReferenceCounting()
throws Exception {
for (int i = 0; i < queues.length; i++) {
assertTrue(parseBuffer(queues[i].remove(),
i).isEvent());
}
-
- assertTrue(bufferConsumer.isRecycled());
}
--- End diff --
How can you verify your ```bufferConsumer.isRecycled``` logic here if you
drop this ?
---
