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

yhu 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 1831cbaae95 Fix data race in test. (#36992)
1831cbaae95 is described below

commit 1831cbaae9581392357ebed400b21fdf68213055
Author: claudevdm <[email protected]>
AuthorDate: Thu Dec 4 11:35:04 2025 -0500

    Fix data race in test. (#36992)
---
 .../org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackersTest.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/sdks/java/core/src/test/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackersTest.java
 
b/sdks/java/core/src/test/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackersTest.java
index 8f7ee9eb25d..7b6f3d47c27 100644
--- 
a/sdks/java/core/src/test/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackersTest.java
+++ 
b/sdks/java/core/src/test/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackersTest.java
@@ -102,7 +102,7 @@ public class RestrictionTrackersTest {
       implements HasProgress {
     private boolean blockTryClaim;
     private boolean blockTrySplit;
-    private boolean isBlocked;
+    private volatile boolean isBlocked;
     public static final Progress REPORT_PROGRESS = Progress.from(2.0, 3.0);
 
     public RestrictionTrackerWithProgress() {

Reply via email to