From dd20950f8ae2342455e6e0a6fd869ffa21ea2153 Mon Sep 17 00:00:00 2001
From: fjy <fangjin@metamarkets.com>
Date: Mon, 12 Aug 2013 13:07:29 -0700
Subject: [PATCH] adding missing continue

---
 .../main/java/com/metamx/druid/coordination/ZkCoordinator.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/server/src/main/java/com/metamx/druid/coordination/ZkCoordinator.java b/server/src/main/java/com/metamx/druid/coordination/ZkCoordinator.java
index afbfe10ada7..b444e1d685b 100644
--- a/server/src/main/java/com/metamx/druid/coordination/ZkCoordinator.java
+++ b/server/src/main/java/com/metamx/druid/coordination/ZkCoordinator.java
@@ -287,6 +287,7 @@ public class ZkCoordinator implements DataSegmentChangeHandler
           log.error(e, "Exception loading segment[%s]", segment.getIdentifier());
           removeSegment(segment);
           segmentFailures.add(segment.getIdentifier());
+          continue;
         }
 
         File segmentInfoCacheFile = new File(config.getSegmentInfoCacheDirectory(), segment.getIdentifier());
@@ -298,6 +299,7 @@ public class ZkCoordinator implements DataSegmentChangeHandler
             log.error(e, "Failed to write to disk segment info cache file[%s]", segmentInfoCacheFile);
             removeSegment(segment);
             segmentFailures.add(segment.getIdentifier());
+            continue;
           }
         }