Xinyu Liu created SAMZA-2761:
--------------------------------
Summary: Shutdown after end-of-stream should wait for all messages
in flight completion
Key: SAMZA-2761
URL: https://issues.apache.org/jira/browse/SAMZA-2761
Project: Samza
Issue Type: Bug
Reporter: Xinyu Liu
Assignee: Xinyu Liu
When all input partitions reach end-of-stream, there might be messages still in
flight, in case of async and multithreading. So we should wait till these
messages being completely processed before shutting down the pipeline.
Otherwise we will not have fully processed all the messages.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
