Repository: flink Updated Branches: refs/heads/master cf7d60242 -> a13f7b234
[hotfix][tests] Remove unused variable Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a13f7b23 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a13f7b23 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a13f7b23 Branch: refs/heads/master Commit: a13f7b23440d865e451f68b1e5e0febb18e0e46f Parents: cf7d602 Author: zentol <[email protected]> Authored: Tue Feb 27 12:20:51 2018 +0100 Committer: zentol <[email protected]> Committed: Tue Feb 27 12:21:12 2018 +0100 ---------------------------------------------------------------------- .../flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java | 3 --- 1 file changed, 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/a13f7b23/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java ---------------------------------------------------------------------- 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 02fdaf9..dc19ad1 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();
