Skip to content

Commit 1731a42

Browse files
committed
Fix ThreadSanitizer data race and optimize AsyncWrapperTest
1 parent 9aed894 commit 1731a42

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/AsyncWrapperTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -179,7 +179,7 @@ public BagState<T> readLater() {
179179

180180
// 4. Used for testing Timer mock implementations.
181181
private static class FakeTimer implements Timer {
182-
private Instant time = Instant.EPOCH;
182+
private volatile Instant time = Instant.EPOCH;
183183

184184
@Override
185185
public void set(Instant absoluteTime) {

0 commit comments

Comments
 (0)