1996fanrui commented on pull request #13885: URL: https://github.com/apache/flink/pull/13885#issuecomment-724426185
I feel it can buffer all streams in Flink. If `bufferSize> 0` then add buffer. If `bufferSize == 0`, the original InputStream is used. So if the buffer has a negative impact, the user can manually close the buffer. In theory, the buffer should not have a negative impact. Please correct me if something I am missed. ---------------------------------------------------------------- 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]
