result = currentChannel.getNextBuffer() | result = Optional.empty() | currentChannel.getNextBuffer() | Optional.empty() | flink | 5b1e127f7b3acd8f82893dda394fbcb7fe93d20d | org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate | | | xyz | currentChannel.getNextBuffer() |
---|
| | | AssignedTo | False |