Sam Whittle created BEAM-6170:
---------------------------------
Summary: NexmarkLauncher stall warning causes benchmark failure
Key: BEAM-6170
URL: https://issues.apache.org/jira/browse/BEAM-6170
Project: Beam
Issue Type: Bug
Components: testing
Reporter: Sam Whittle
Assignee: Sam Whittle
The monitoring in the NexmarkLauncher watches the pipeline results and source
for events. If no events are consumed from the source or published to the
output for over
STUCK_WARNING_DELAY it prints an warning message:
"WARNING: streaming query appears to have been stuck for %d min.",
However it also adds this to the errors list, which causes the pipeline to
terminate by throwing an exception. There is a separate STUCK_TERMINATE_DELAY
which is used to terminate the pipeline. It seems inconsistent to cause the
pipeline to fail with the warning timeout. It is also not 100% accurrate
because the pipeline may be busy processing stages other than the input or
output.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
