You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gobblin.apache.org by su...@apache.org on 2021/08/24 16:08:20 UTC
[gobblin] branch master updated: GOBBLIN-1523: Change logging of
live instances in Gobblin cluster to debug level (#3374)
This is an automated email from the ASF dual-hosted git repository.
suvasude pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git
The following commit(s) were added to refs/heads/master by this push:
new 45c9831 GOBBLIN-1523: Change logging of live instances in Gobblin cluster to debug level (#3374)
45c9831 is described below
commit 45c98317674386021680c2581a16184e20cd0b78
Author: Sudarshan Vasudevan <su...@gmail.com>
AuthorDate: Tue Aug 24 09:08:12 2021 -0700
GOBBLIN-1523: Change logging of live instances in Gobblin cluster to debug level (#3374)
---
.../java/org/apache/gobblin/cluster/GobblinHelixMultiManager.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMultiManager.java b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMultiManager.java
index 7b25134..5e2b727 100644
--- a/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMultiManager.java
+++ b/gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMultiManager.java
@@ -311,11 +311,12 @@ public class GobblinHelixMultiManager implements StandardMetricsBridge {
* A custom implementation of {@link LiveInstanceChangeListener}.
*/
private static class GobblinLiveInstanceChangeListener implements LiveInstanceChangeListener {
-
@Override
public void onLiveInstanceChange(List<LiveInstance> liveInstances, NotificationContext changeContext) {
- for (LiveInstance liveInstance : liveInstances) {
- log.info("Live Helix participant instance: " + liveInstance.getInstanceName());
+ if (log.isDebugEnabled()) {
+ for (LiveInstance liveInstance : liveInstances) {
+ log.debug("Live Helix participant instance: " + liveInstance.getInstanceName());
+ }
}
}
}