rkhachatryan commented on pull request #13351: URL: https://github.com/apache/flink/pull/13351#issuecomment-705687454
I rebased the PR and resolved conflicts with FLINK-19027 by moving the assignment of exclusive buffers for `RecoveredInputChannel` into it's `requestBufferBlocking` method. I also replaced `RemoteInputChannel.assignExclusiveSegments()` with `InputChannel.setup()` make it clear that `RecoveredInputChannel` doesn't need setup and avoid if/casts (e4946c0fbc1a46d866b29edff083eb4e2370e437). @pnowojski, @AHeise please take a look. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
