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;