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

Indexer: Demote WARN to DEBUG for tasks that don't register Appenderators. (#11939)

This commit is contained in:
Gian Merlino 2021-11-18 07:54:43 -08:00 committed by GitHub
parent 29710789a4
commit a04f99a950
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/src/main/java/org/apache/druid/segment/realtime/appenderator/UnifiedIndexerAppenderatorsManager.java
View File

@ -316,11 +316,13 @@ public class UnifiedIndexerAppenderatorsManager implements AppenderatorsManager
synchronized (this) {
DatasourceBundle datasourceBundle = datasourceBundles.get(dataSource);
if (datasourceBundle == null) {
LOG.error("Could not find datasource bundle for [%s], task [%s]", dataSource, taskId);
// Not a warning, because not all tasks use Appenderators.
LOG.debug("Could not find datasource bundle for [%s], task [%s]", dataSource, taskId);
} else {
List<Appenderator> existingAppenderators = datasourceBundle.taskAppenderatorMap.remove(taskId);
if (existingAppenderators == null) {
LOG.error("Tried to remove appenderators for task [%s] but none were found.", taskId);
// Not a warning, because not all tasks use Appenderators.
LOG.debug("Tried to remove appenderators for task [%s] but none were found.", taskId);
}
if (datasourceBundle.taskAppenderatorMap.isEmpty()) {
datasourceBundles.remove(dataSource);