Details
-
Bug
-
Status: Resolved
-
P1
-
Resolution: Fixed
-
None
-
None
Description
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
// 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()) {
Attachments
Issue Links
- links to
