[
https://issues.apache.org/jira/browse/BEAM-10286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kenneth Knowles updated BEAM-10286:
-----------------------------------
Status: Open (was: Triage Needed)
> ExecutorServiceParallelExecutor.waitUntilFinish drops exceptions
> ----------------------------------------------------------------
>
> Key: BEAM-10286
> URL: https://issues.apache.org/jira/browse/BEAM-10286
> Project: Beam
> Issue Type: Bug
> Components: runner-direct
> Reporter: Andrew Pilloud
> Assignee: Andrew Pilloud
> Priority: P1
>
> This is a race, I have been unable to reproduce in an isolated test, but it
> is trivial to reproduce in a google internal integration suite with the
> following change to
> runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java
> {code}
> // Get an update; don't block forever if another thread has handled
> it. The call to poll will
> // wait the entire timeout; this call primarily exists to relinquish
> any core.
> VisibleExecutorUpdate update =
> visibleUpdates.tryNext(Duration.millis(25L));
> + Thread.sleep(100);
>
> if (update == null && pipelineState.get().isTerminal()) {
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
