diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java index 313fe13db1047460a01f68632eb0178d11fb2e0d..fc9dd94e2e3b0e60cba6d41f15050cb16f9a7094 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java @@ -429,7 +429,7 @@ public class CheckpointStatsTracker { private class LatestCompletedCheckpointAlignmentBufferedGauge implements Gauge { @Override public Long getValue() { - CompletedCheckpointStats completed = latestCompletedCheckpoint;; + CompletedCheckpointStats completed = latestCompletedCheckpoint; if (completed != null) { return completed.getAlignmentBuffered(); } else { diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTableTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTableTest.java index 828982174abee805f0bc3bf1240849402f8848cf..09a0620be96d53602cbc9c2b631afcc72e19a28f 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTableTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTableTest.java @@ -396,8 +396,8 @@ public class CopyOnWriteStateTableTest extends TestLogger { public void testSerializerDuplicationInSnapshot() throws IOException { final TestDuplicateSerializer namespaceSerializer = new TestDuplicateSerializer(); - final TestDuplicateSerializer stateSerializer = new TestDuplicateSerializer();; - final TestDuplicateSerializer keySerializer = new TestDuplicateSerializer();; + final TestDuplicateSerializer stateSerializer = new TestDuplicateSerializer(); + final TestDuplicateSerializer keySerializer = new TestDuplicateSerializer(); RegisteredKeyedBackendStateMetaInfo metaInfo = new RegisteredKeyedBackendStateMetaInfo<>(