[
https://issues.apache.org/jira/browse/APEXCORE-599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15866753#comment-15866753
]
Vlad Rozov commented on APEXCORE-599:
-------------------------------------
[~thw] Can it be caused by APEXCORE-645?
> 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.15#6346)
