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() {