[hotfix][tests] Remove unnecessary volatile in RescalingITCase

akalash · Apr 15, 2021 · 28deff9 · 28deff9
1 parent 2a4265d
commit 28deff9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java
@@ -784,7 +784,7 @@ private static class SubtaskIndexFlatMapper
 
         private static final long serialVersionUID = 5273172591283191348L;
 
-        private static volatile CountDownLatch workCompletedLatch = new CountDownLatch(1);
+        private static CountDownLatch workCompletedLatch = new CountDownLatch(1);
 
         private transient ValueState<Integer> counter;
         private transient ValueState<Integer> sum;
@@ -851,7 +851,7 @@ public void invoke(IN value) throws Exception {
     private static class StateSourceBase extends RichParallelSourceFunction<Integer> {
 
         private static final long serialVersionUID = 7512206069681177940L;
-        private static volatile CountDownLatch workStartedLatch = new CountDownLatch(1);
+        private static CountDownLatch workStartedLatch = new CountDownLatch(1);
 
         protected volatile int counter = 0;
         protected volatile boolean running = true;