| bufferOrEvent = barrierHandler.getNextNonBlocked() | bufferOrEvent = barrierHandler.pollNext() | barrierHandler.getNextNonBlocked() | barrierHandler.pollNext() | flink | 8d281f8b2b3d170385f38e8f88ec1df09d0d0efe | org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | | | _1 | bufferOrEvent |
|---|
| _2 | bufferOrEvent |
|---|
| | | | AssignedTo | True |
| bufferOrEvent = barrierHandler.getNextNonBlocked() | bufferOrEvent = barrierHandler.pollNext() | barrierHandler.getNextNonBlocked() | barrierHandler.pollNext() | flink | 8d281f8b2b3d170385f38e8f88ec1df09d0d0efe | org.apache.flink.streaming.runtime.io.StreamInputProcessor | | | _1 | bufferOrEvent |
|---|
| _2 | bufferOrEvent |
|---|
| | | | AssignedTo | True |