mirror of https://github.com/apache/druid.git
Coordinator fix exception caused by additional logging (#5988)
* fix explosion in curator load queue peon caused by additional logging, as well as annoying chatty log * remove log message
This commit is contained in:
parent
153eb26262
commit
ac194cc082
|
@ -386,13 +386,13 @@ public class CuratorLoadQueuePeon extends LoadQueuePeon
|
||||||
);
|
);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
actionCompleted();
|
|
||||||
log.info(
|
log.info(
|
||||||
"Server[%s] done processing %s of segment [%s]",
|
"Server[%s] done processing %s of segment [%s]",
|
||||||
basePath,
|
basePath,
|
||||||
currentlyProcessing.getType() == LOAD ? "load" : "drop",
|
currentlyProcessing.getType() == LOAD ? "load" : "drop",
|
||||||
path
|
path
|
||||||
);
|
);
|
||||||
|
actionCompleted();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -247,7 +247,6 @@ public abstract class LoadRule implements Rule
|
||||||
createLoadQueueSizeLimitingPredicate(params),
|
createLoadQueueSizeLimitingPredicate(params),
|
||||||
segment
|
segment
|
||||||
);
|
);
|
||||||
log.info("Assigned %d replicas in tier [%s]", numAssigned, tier);
|
|
||||||
stats.addToTieredStat(ASSIGNED_COUNT, tier, numAssigned);
|
stats.addToTieredStat(ASSIGNED_COUNT, tier, numAssigned);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue