stankiewicz opened a new pull request, #31037: URL: https://github.com/apache/beam/pull/31037
UnboundedReader is controlled with UnboundedReaderMaxReadTimeSec and UnboundedReaderMaxElements. For sub second latency user has to set UnboundedReaderMaxElements to 1 which is not flexible as there may be multiple situation where there are more elements. In this change UnboundedReaderMaxReadTimeSec becomes double. Change is backward compatible. Unlike #31036, this doesn't introduce additional flag. -- 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]
