(beam) branch release-2.54.0 updated: Marks failed bit as volatile since multiple threads read and write it. (#30216)

[lostluck]

This is an automated email from the ASF dual-hosted git repository.

lostluck pushed a commit to branch release-2.54.0
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/release-2.54.0 by this push:
     new 7cd144d2985 Marks failed bit as volatile since multiple threads read 
and write it. (#30216)
7cd144d2985 is described below

commit 7cd144d2985b5cb2525fe7f502230da07cfb381e
Author: Robert Burke <lostl...@users.noreply.github.com>
AuthorDate: Mon Feb 5 15:59:32 2024 -0800

    Marks failed bit as volatile since multiple threads read and write it. 
(#30216)
    
    Co-authored-by: lostluck <13907733+lostl...@users.noreply.github.com>
---
 .../java/org/apache/beam/runners/dataflow/worker/streaming/Work.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/Work.java
 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/Work.java
index 69f2a0dcee7..8d4ba33a1ab 100644
--- 
a/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/Work.java
+++ 
b/runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/Work.java
@@ -50,7 +50,7 @@ public class Work implements Runnable {
   private final Consumer<Work> processWorkFn;
   private TimedState currentState;
 
-  private boolean isFailed;
+  private volatile boolean isFailed;
 
   private Work(Windmill.WorkItem workItem, Supplier<Instant> clock, 
Consumer<Work> processWorkFn) {
     this.workItem = workItem;