available = receivedBuffers.size() | wasEmpty = receivedBuffers.isEmpty() | receivedBuffers.size() | receivedBuffers.isEmpty() | flink | 5526ec7eefe858d9535f23a057b9f2c6c725ab92 | org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel | | | | | | AssignedTo | True |