lindong28 commented on PR #21690: URL: https://github.com/apache/flink/pull/21690#issuecomment-1396398435
> It's strange that MultiInputStreamTask-D constructed a DataOutput-C, and OneInputStreamTask-B calls the DataOutput- > C::emitRecord constructed for MultiInputStreamTask-D. I think it should be a bug if it happens. @1996fanrui Hmm... I thought we have agreed that "A and B should not care about the interface of C is determined by D". This is because DataOutput is an interface and the caller should be able to use it based on its API semantics without knowing who constructed it, right? Do you suggest that we should now couple the caller the DataOutput with the code that constructed it? It seems to break the typical pattern of how we use interface.. -- 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]
