1996fanrui commented on PR #21690: URL: https://github.com/apache/flink/pull/21690#issuecomment-1396507794
> Are you suggesting that we should now couple the caller of DataOutput with the code that constructed it? In fact, the code in the master branch did this a long time ago. `OneInputStreamTask` has inner class `StreamTaskNetworkOutput`, and `OneInputStreamTask#createDataOutput` will create it. `StreamMultipleInputProcessorFactory` has inner class `StreamTaskSourceOutput`, and `MultipleInputStreamTask#createInputProcessor -> StreamMultipleInputProcessorFactory#create` will create it. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
