diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/JobManagerHACheckpointRecoveryITCase.java b/flink-tests/src/test/java/org/apache/flink/test/recovery/JobManagerHACheckpointRecoveryITCase.java index 262f78ac4b0f7..f66e52c944c8f 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recovery/JobManagerHACheckpointRecoveryITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/JobManagerHACheckpointRecoveryITCase.java @@ -97,10 +97,16 @@ public class JobManagerHACheckpointRecoveryITCase extends TestLogger { @AfterClass public static void tearDown() throws Exception { - ZooKeeper.shutdown(); + try { + ZooKeeper.shutdown(); + } catch (Exception ignored) { + } - if (FileStateBackendBasePath != null) { - FileUtils.deleteDirectory(FileStateBackendBasePath); + try { + if (FileStateBackendBasePath != null) { + FileUtils.deleteDirectory(FileStateBackendBasePath); + } + } catch (IOException ignored) { } }