git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[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 <cjwylie@xxxxxxxxx>
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@xxxxxxxxxxxxxxxx
For additional commands, e-mail: dev-help@xxxxxxxxxxxxxxxx




( ! ) Warning: include(msgfooter.php): failed to open stream: No such file or directory in /var/www/git/apache-druid-developers/msg00592.html on line 130
Call Stack
#TimeMemoryFunctionLocation
10.0015368728{main}( ).../msg00592.html:0

( ! ) Warning: include(): Failed opening 'msgfooter.php' for inclusion (include_path='.:/var/www/git') in /var/www/git/apache-druid-developers/msg00592.html on line 130
Call Stack
#TimeMemoryFunctionLocation
10.0015368728{main}( ).../msg00592.html:0