Thomas Weise created APEXCORE-599:
-------------------------------------
Summary: Data not fully processed when operator terminates via
ShutdownException
Key: APEXCORE-599
URL: https://issues.apache.org/jira/browse/APEXCORE-599
Project: Apache Apex Core
Issue Type: Bug
Affects Versions: 3.5.0
Reporter: Thomas Weise
Observed in the form of flaky unit tests in Beam. The pipelines terminate using
shutdown by the operator when there is no more input and occasionally the test
will fail because the cluster exits without having processed fully. The bandaid
is to have a delay before shutdown is issued, allowing the last tuples to be
pushed downstream. See BEAM-1140 for details.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
