ajothomas opened a new pull request, #1692: URL: https://github.com/apache/samza/pull/1692
# Description - Some implementations of `SystemProducer` can have an async implementation of the send API. - `CoordinatorStreamWriter` writes only one message and closes the `CoordinatorStreamSystemProducer`. There is a chance that the producer close will be called before the async write can complete. # Changes - We will call `flush` as a part of `CoordinatorStreamSystemProducer`'s `stop` implementation so that the underlying producer flushes out messages prior to calling closing the producer. # Tests - `./gradlew build` - Tested with sample apps # API Changes None # Usage Instructions None # Upgrade Instructions None -- 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]
