diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperTestEnvironment.java b/flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperTestEnvironment.java index 94e198805179e9a202223a9ced7c8ff4401daf0b..5aca687cc20ef72790dabf065d74783bf4cca559 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperTestEnvironment.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperTestEnvironment.java @@ -137,7 +137,19 @@ public class ZooKeeperTestEnvironment { */ public void deleteAll() throws Exception { final String path = "/" + client.getNamespace(); - ZKPaths.deleteChildren(client.getZookeeperClient().getZooKeeper(), path, false); + + for (int attempt = 0; attempt < 3; attempt++) { + try { + ZKPaths.deleteChildren(client.getZookeeperClient().getZooKeeper(), path, false); + break; + } + catch (org.apache.zookeeper.KeeperException.NoNodeException e) { + // that seems all right. if one of the children we want to delete is + // actually already deleted, that's fine. + + // still, fall through the loop to delete the other children + } + } } }