From 8bd98e09d2f9575c7fb4177d79979ebb271298bb Mon Sep 17 00:00:00 2001 From: Ufuk Celebi Date: Thu, 3 Dec 2015 14:33:04 +0100 Subject: [PATCH] [FLINK-3096] Retry cleaned checkpoint directory check --- .../apache/flink/test/recovery/ChaosMonkeyITCase.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/ChaosMonkeyITCase.java b/flink-tests/src/test/java/org/apache/flink/test/recovery/ChaosMonkeyITCase.java index e436f5f3b18..acc85699251 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/recovery/ChaosMonkeyITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/ChaosMonkeyITCase.java @@ -533,8 +533,14 @@ public class ChaosMonkeyITCase extends TestLogger { LOG.info("Checking " + ZooKeeper.getClientNamespace() + ConfigConstants.DEFAULT_ZOOKEEPER_CHECKPOINTS_PATH); - List checkpoints = ZooKeeper.getChildren(ConfigConstants.DEFAULT_ZOOKEEPER_CHECKPOINTS_PATH); - assertEquals("Unclean checkpoints: " + checkpoints, 0, checkpoints.size()); + + for (int i = 0; i < 10; i++) { + List checkpoints = ZooKeeper.getChildren(ConfigConstants.DEFAULT_ZOOKEEPER_CHECKPOINTS_PATH); + assertEquals("Unclean checkpoints: " + checkpoints, 0, checkpoints.size()); + + LOG.info("Unclean... retrying in 2s."); + Thread.sleep(2000); + } LOG.info("Checking " + ZooKeeper.getClientNamespace() + ConfigConstants.DEFAULT_ZOOKEEPER_CHECKPOINT_COUNTER_PATH); -- GitLab