(beam) branch master updated: Volatile heartbeat (#30148)

[an...@apache.org]

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

anandinguva pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 5a9a27cbafa Volatile heartbeat (#30148)
5a9a27cbafa is described below

commit 5a9a27cbafa5b08f4380e74beb91292ac2e8f85f
Author: Andrew Crites <cr...@google.com>
AuthorDate: Tue Jan 30 06:55:16 2024 -0800

    Volatile heartbeat (#30148)
---
 .../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;