commit | ff144a2dda1362ad99b7885907847be2d2734215 | [log] [tgz] |
---|---|---|
author | Sam Whittle <samuelw@google.com> | Sat Apr 17 11:34:03 2021 -0700 |
committer | Sam Whittle <samuelw@google.com> | Sat Apr 17 11:34:03 2021 -0700 |
tree | e0eaec09fb51694c10cd01fb5bba9917f3ee8cb3 | |
parent | 985e2f095d150261e998f58cf048e48a909d5b2b [diff] |
[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; } }