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

improve alert 

skip doing false alert when the coordinator looses leadership
This commit is contained in:
nishantmonu51 2015-03-18 09:42:22 +05:30
parent 36b4c6a371
commit 21cd75bcf6
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;
} }
} }