Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4533#discussion_r145746280
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
---
@@ -378,32 +387,47 @@ public void testReleaseExclusiveBuffers() throws
Exception {
/**
* Tests {@link BufferPool#requestBuffer()}, verifying the remote input
channel tries to request
- * floating buffers once receiving the producer's backlog.
+ * floating buffers once receiving the producer's backlog, and then
notifies credit available after
+ * receiving floating buffers.
*/
@Test
public void testRequestFloatingBuffersOnBuffer() throws Exception {
+ // Config
+ final Tuple2<Integer, Integer> backoff = new Tuple2<>(0, 0);
+
// Setup
final BufferPool bufferPool = mock(BufferPool.class);
when(bufferPool.requestBuffer()).thenReturn(TestBufferFactory.createBuffer());
+ final PartitionRequestClient connClient =
mock(PartitionRequestClient.class);
--- End diff --
refresh the latest code
---
