You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2020/05/16 21:04:55 UTC
[flink] 04/06: [hotfix][runtime] Remove useless local variable in
CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 080248d7426fd3d9339c8bf7f998428a5adf0458
Author: felixzheng <fe...@gmail.com>
AuthorDate: Mon May 11 12:44:19 2020 +0800
[hotfix][runtime] Remove useless local variable in CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained
This closes #12066
---
.../apache/flink/runtime/checkpoint/CompletedCheckpointStoreTest.java | 2 --
1 file changed, 2 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStoreTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStoreTest.java
index 17c470e..bdde348 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStoreTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStoreTest.java
@@ -105,8 +105,6 @@ public abstract class CompletedCheckpointStoreTest extends TestLogger {
assertEquals(1, checkpoints.getNumberOfRetainedCheckpoints());
for (int i = 1; i < expected.length; i++) {
- Collection<OperatorState> taskStates = expected[i - 1].getOperatorStates().values();
-
checkpoints.addCheckpoint(expected[i]);
// The ZooKeeper implementation discards asynchronously