zhijiangW commented on pull request #12460: URL: https://github.com/apache/flink/pull/12460#issuecomment-638807938
FYI: Actually I also planned to get ride of `ThreadSafeUnaligner#storeNewBuffers` variable after refactoring the related processes a bit in this PR. Since the semantic of this state is hard to understand and we can also get ride of `numberOfInputChannelsPerGate` argument to simplify this class as a result. It is almost done on my local but brought some unexpected other failures, i am not sure whether have time to further focus on it. Let's see then. ---------------------------------------------------------------- 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]
