| commit | 41b5e3e9db493597165340ff20b1e0dd976e92eb | [log] [tgz] |
|---|---|---|
| author | Chesnay Schepler <chesnay@apache.org> | Thu Jul 22 11:29:30 2021 +0200 |
| committer | Chesnay Schepler <chesnay@apache.org> | Thu Jul 22 11:29:30 2021 +0200 |
| tree | c7258f93010287ddc950923e777c7c6a390ae986 | |
| parent | a8f7c71ecb244ef6937deb10a2555637b14da3be [diff] |
[FLINK-23469] Fix MiniCluster leak
diff --git a/src/main/java/org/apache/flink/benchmark/StateBackendBenchmarkBase.java b/src/main/java/org/apache/flink/benchmark/StateBackendBenchmarkBase.java index cbbbd05..7bf24c2 100644 --- a/src/main/java/org/apache/flink/benchmark/StateBackendBenchmarkBase.java +++ b/src/main/java/org/apache/flink/benchmark/StateBackendBenchmarkBase.java
@@ -87,7 +87,9 @@ source = env.addSource(new IntegerLongSource(numberOfElements, recordsPerInvocation)); } - public void tearDown() throws IOException { + @Override + public void tearDown() throws Exception { + super.tearDown(); FileUtils.deleteDirectory(checkpointDir); } }