You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@druid.apache.org by jo...@apache.org on 2018/07/11 23:13:36 UTC
[incubator-druid] branch master updated: Coordinator fix exception
caused by additional logging (#5988)
This is an automated email from the ASF dual-hosted git repository.
jonwei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git
The following commit(s) were added to refs/heads/master by this push:
new ac194cc Coordinator fix exception caused by additional logging (#5988)
ac194cc is described below
commit ac194cc082fe6dabb2ddae0780d83d58ea182e5d
Author: Clint Wylie <cj...@gmail.com>
AuthorDate: Wed Jul 11 16:13:32 2018 -0700
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
---
.../src/main/java/io/druid/server/coordinator/CuratorLoadQueuePeon.java | 2 +-
server/src/main/java/io/druid/server/coordinator/rules/LoadRule.java | 1 -
2 files changed, 1 insertion(+), 2 deletions(-)
diff --git a/server/src/main/java/io/druid/server/coordinator/CuratorLoadQueuePeon.java b/server/src/main/java/io/druid/server/coordinator/CuratorLoadQueuePeon.java
index 58ffb75..ee0ee78 100644
--- a/server/src/main/java/io/druid/server/coordinator/CuratorLoadQueuePeon.java
+++ b/server/src/main/java/io/druid/server/coordinator/CuratorLoadQueuePeon.java
@@ -386,13 +386,13 @@ public class CuratorLoadQueuePeon extends LoadQueuePeon
);
return;
}
- actionCompleted();
log.info(
"Server[%s] done processing %s of segment [%s]",
basePath,
currentlyProcessing.getType() == LOAD ? "load" : "drop",
path
);
+ actionCompleted();
}
}
diff --git a/server/src/main/java/io/druid/server/coordinator/rules/LoadRule.java b/server/src/main/java/io/druid/server/coordinator/rules/LoadRule.java
index d96b912..11ba9c2 100644
--- a/server/src/main/java/io/druid/server/coordinator/rules/LoadRule.java
+++ b/server/src/main/java/io/druid/server/coordinator/rules/LoadRule.java
@@ -247,7 +247,6 @@ public abstract class LoadRule implements Rule
createLoadQueueSizeLimitingPredicate(params),
segment
);
- log.info("Assigned %d replicas in tier [%s]", numAssigned, tier);
stats.addToTieredStat(ASSIGNED_COUNT, tier, numAssigned);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@druid.apache.org
For additional commands, e-mail: dev-help@druid.apache.org