Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1224 from metamx/alert-improve 

skip raising false alert when the coordinator looses leadership
This commit is contained in:
Xavier Léauté 2015-04-07 10:11:34 -07:00
parent 9d0267d6f3 21cd75bcf6
commit 44e23a8267
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/src/main/java/io/druid/server/coordinator/LoadQueuePeon.java
View File

@ -86,6 +86,7 @@ public class LoadQueuePeon
private final Object lock = new Object(); private final Object lock = new Object();
private volatile SegmentHolder currentlyProcessing = null; private volatile SegmentHolder currentlyProcessing = null;
private boolean stopped = false;
LoadQueuePeon( LoadQueuePeon(
CuratorFramework curator, CuratorFramework curator,
@ -209,9 +210,12 @@ public class LoadQueuePeon
{ {
synchronized (lock) { synchronized (lock) {
try { try {
// expected when the coordinator looses leadership and LoadQueuePeon is stopped.
if (currentlyProcessing == null) { if (currentlyProcessing == null) {
if(!stopped) {
log.makeAlert("Crazy race condition! server[%s]", basePath) log.makeAlert("Crazy race condition! server[%s]", basePath)
.emit(); .emit();
}
actionCompleted(); actionCompleted();
doNext(); doNext();
return; return;
@ -347,6 +351,7 @@ public class LoadQueuePeon
queuedSize.set(0L); queuedSize.set(0L);
failedAssignCount.set(0); failedAssignCount.set(0);
stopped = true;
} }
} }