Andrew Pilloud created BEAM-10286:
-------------------------------------
Summary: 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
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)
