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 02fdaf99981155ac2a1f3101fba03a797f12250f..dc19ad1d64712eb371b7d4a0eeea764365019d24 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();