commit | 1297cf396d9b1a41b67450f18a9c79d885c7542d | [log] [tgz] |
---|---|---|
author | fjy <fangjin@metamarkets.com> | Wed Feb 05 15:12:22 2014 -0800 |
committer | fjy <fangjin@metamarkets.com> | Wed Feb 05 15:12:22 2014 -0800 |
tree | caa277f795d1c0785cec3d5c879a5492da736234 | |
parent | d06e349909dfe22a437f5fe729a6ab57ae433dfd [diff] |
add more check
diff --git a/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java b/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java index 86edd68..3fc6b25 100644 --- a/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java +++ b/server/src/main/java/io/druid/server/coordinator/DruidCoordinator.java
@@ -527,7 +527,7 @@ @Override public ScheduledExecutors.Signal call() { - if (leader) { + if (leader && startingLeaderCounter == leaderCounter) { theRunnable.run(); } // (We might no longer be leader or leadership has changed)