[hotfix][tests] Remove unused variable

a13f7b23 · zentol · cf7d6024 · a13f7b23
隐藏空白更改
内联并排

Showing with 0 addition and 3 deletion

flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java ...nk/test/misc/SuccessAfterNetworkBuffersFailureITCase.java +0 -3

未找到文件。
--- 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();