stankiewicz opened a new pull request, #31036: URL: https://github.com/apache/beam/pull/31036
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 UnboundedReaderMaxReadTime will be controlled by UnboundedReaderMaxReadTimeSec+UnboundedReaderMaxReadTimeMs. For backward compatibility UnboundedReaderMaxReadTimeMs default is 0 and UnboundedReaderMaxReadTime is sum of both. -- 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]
