We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ece2beb commit 1831cbaCopy full SHA for 1831cba
sdks/java/core/src/test/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackersTest.java
@@ -102,7 +102,7 @@ private static class RestrictionTrackerWithProgress extends RestrictionTracker<O
102
implements HasProgress {
103
private boolean blockTryClaim;
104
private boolean blockTrySplit;
105
- private boolean isBlocked;
+ private volatile boolean isBlocked;
106
public static final Progress REPORT_PROGRESS = Progress.from(2.0, 3.0);
107
108
public RestrictionTrackerWithProgress() {
0 commit comments