From a13f7b23440d865e451f68b1e5e0febb18e0e46f Mon Sep 17 00:00:00 2001 From: zentol Date: Tue, 27 Feb 2018 12:20:51 +0100 Subject: [PATCH] [hotfix][tests] Remove unused variable --- .../test/misc/SuccessAfterNetworkBuffersFailureITCase.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java b/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java index 02fdaf99981..dc19ad1d647 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java @@ -32,7 +32,6 @@ import org.apache.flink.examples.java.clustering.util.KMeansData; import org.apache.flink.examples.java.graph.ConnectedComponents; import org.apache.flink.examples.java.graph.util.ConnectedComponentsData; import org.apache.flink.runtime.client.JobExecutionException; -import org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster; import org.apache.flink.test.util.MiniClusterResource; import org.apache.flink.util.TestLogger; @@ -67,8 +66,6 @@ public class SuccessAfterNetworkBuffersFailureITCase extends TestLogger { @Test public void testSuccessfulProgramAfterFailure() { - LocalFlinkMiniCluster cluster = null; - try { ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); -- GitLab