You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by gi...@apache.org on 2021/11/18 15:55:18 UTC
[druid] branch master updated: Indexer: Demote WARN to DEBUG for tasks that don't register Appenderators. (#11939)
This is an automated email from the ASF dual-hosted git repository.
gian pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new a04f99a Indexer: Demote WARN to DEBUG for tasks that don't register Appenderators. (#11939)
a04f99a is described below
commit a04f99a95047fa417b9effeca109ed334cbbfa74
Author: Gian Merlino <gi...@gmail.com>
AuthorDate: Thu Nov 18 07:54:43 2021 -0800
Indexer: Demote WARN to DEBUG for tasks that don't register Appenderators. (#11939)
---
.../realtime/appenderator/UnifiedIndexerAppenderatorsManager.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/server/src/main/java/org/apache/druid/segment/realtime/appenderator/UnifiedIndexerAppenderatorsManager.java b/server/src/main/java/org/apache/druid/segment/realtime/appenderator/UnifiedIndexerAppenderatorsManager.java
index 23a00c7..a815f19 100644
--- a/server/src/main/java/org/apache/druid/segment/realtime/appenderator/UnifiedIndexerAppenderatorsManager.java
+++ b/server/src/main/java/org/apache/druid/segment/realtime/appenderator/UnifiedIndexerAppenderatorsManager.java
@@ -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);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org