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 16:27:51 UTC

[flink] 02/13: [hotfix][tests] Remove unused temp folder in CheckpointMetadataLoadingTest

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 e1fc86b7ac8771da4224c1ebb96fad04831bd3fa
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Wed May 13 15:15:04 2020 +0200

    [hotfix][tests] Remove unused temp folder in CheckpointMetadataLoadingTest
---
 .../flink/runtime/checkpoint/CheckpointMetadataLoadingTest.java    | 7 -------
 1 file changed, 7 deletions(-)

diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointMetadataLoadingTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointMetadataLoadingTest.java
index fc93b2c..557e8ba 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointMetadataLoadingTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointMetadataLoadingTest.java
@@ -30,12 +30,9 @@ import org.apache.flink.runtime.state.StreamStateHandle;
 import org.apache.flink.runtime.state.memory.ByteStreamStateHandle;
 import org.apache.flink.runtime.state.testutils.TestCompletedCheckpointStorageLocation;
 
-import org.junit.Rule;
 import org.junit.Test;
-import org.junit.rules.TemporaryFolder;
 
 import java.io.ByteArrayOutputStream;
-import java.io.File;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.Map;
@@ -57,9 +54,6 @@ import static org.mockito.Mockito.when;
  */
 public class CheckpointMetadataLoadingTest {
 
-	@Rule
-	public final TemporaryFolder tmpFolder = new TemporaryFolder();
-
 	/**
 	 * Tests loading and validation of savepoints with correct setup,
 	 * parallelism mismatch, and a missing task.
@@ -67,7 +61,6 @@ public class CheckpointMetadataLoadingTest {
 	@Test
 	public void testLoadAndValidateSavepoint() throws Exception {
 		final Random rnd = new Random();
-		File tmp = tmpFolder.newFolder();
 
 		int parallelism = 128128;
 		long checkpointId = Integer.MAX_VALUE + 123123L;