| commit | faaf6468ef961d349eafd68b7e5107488fd195db | [log] [tgz] |
|---|---|---|
| author | Kenn Knowles <kenn@apache.org> | Mon Apr 19 15:31:27 2021 -0700 |
| committer | GitHub <noreply@github.com> | Mon Apr 19 15:31:27 2021 -0700 |
| tree | d0e3f025062ff5af2c080118436b2971d9d3dbf7 | |
| parent | b9de6b6323ed8f235134c0ae4587797b22538b87 [diff] | |
| parent | ff144a2dda1362ad99b7885907847be2d2734215 [diff] |
Merge pull request #14572: [BEAM-12118] Fix racy precondition exception in QueueingBeamFnDataClient
diff --git a/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/QueueingBeamFnDataClient.java b/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/QueueingBeamFnDataClient.java index a1180f9..21d0b14 100644 --- a/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/QueueingBeamFnDataClient.java +++ b/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/QueueingBeamFnDataClient.java
@@ -97,7 +97,7 @@ } boolean isEmpty() { - return queue.isEmpty(); + return queue.isEmpty() || queue.peek() == POISON; } }