flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhue...@apache.org
Subject [2/2] flink git commit: [FLINK-7644] [runtime] Remove double semicolon.
Date Thu, 21 Sep 2017 12:16:46 GMT
[FLINK-7644] [runtime] Remove double semicolon.

This closes #4692.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6c315be0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6c315be0
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6c315be0

Branch: refs/heads/master
Commit: 6c315be0928a0ffc214e60d6d9240e79db055a0c
Parents: 6886f63
Author: yew1eb <yew1eb@gmail.com>
Authored: Thu Sep 21 14:07:38 2017 +0800
Committer: Fabian Hueske <fhueske@apache.org>
Committed: Thu Sep 21 14:11:42 2017 +0200

----------------------------------------------------------------------
 .../apache/flink/runtime/checkpoint/CheckpointStatsTracker.java  | 2 +-
 .../flink/runtime/state/heap/CopyOnWriteStateTableTest.java      | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/6c315be0/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java
----------------------------------------------------------------------
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 313fe13..fc9dd94 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<Long>
{
 		@Override
 		public Long getValue() {
-			CompletedCheckpointStats completed = latestCompletedCheckpoint;;
+			CompletedCheckpointStats completed = latestCompletedCheckpoint;
 			if (completed != null) {
 				return completed.getAlignmentBuffered();
 			} else {

http://git-wip-us.apache.org/repos/asf/flink/blob/6c315be0/flink-runtime/src/test/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateTableTest.java
----------------------------------------------------------------------
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 8289821..09a0620 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<Integer, Integer> metaInfo =
 			new RegisteredKeyedBackendStateMetaInfo<>(


Mime
View raw message