This is an automated email from the ASF dual-hosted git repository.

zihanli58 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 e8409b6da [GOBBLIN-1645]Change the prefix of dagManager heartbeat to 
make it consistent with other metrics (#3505)
e8409b6da is described below

commit e8409b6dad12533b2bd690be7aa33d2930eea020
Author: Zihan Li <[email protected]>
AuthorDate: Wed May 11 10:45:27 2022 -0700

    [GOBBLIN-1645]Change the prefix of dagManager heartbeat to make it 
consistent with other metrics (#3505)
    
    * address comments
    
    * use connectionmanager when httpclient is not cloesable
    
    * [GOBBLIN-1645]Change the prefix of dagManager heartbeat to make it 
consistent with other metrics
    
    Co-authored-by: Zihan Li <[email protected]>
---
 .../org/apache/gobblin/service/modules/orchestration/DagManager.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java
 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java
index 41b407905..eeb6b70b3 100644
--- 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java
+++ 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManager.java
@@ -136,7 +136,7 @@ public class DagManager extends AbstractIdleService {
   private static final long DEFAULT_FAILED_DAG_RETENTION_TIME = 7L;
   public static final String FAILED_DAG_POLLING_INTERVAL = 
FAILED_DAG_STATESTORE_PREFIX + ".retention.pollingIntervalMinutes";
   public static final Integer DEFAULT_FAILED_DAG_POLLING_INTERVAL = 60;
-  public static final String DAG_MANAGER_HEARTBEAT = 
"gobblin.dagManager.heartbeat-%s";
+  public static final String DAG_MANAGER_HEARTBEAT = 
ServiceMetricNames.GOBBLIN_SERVICE_PREFIX + ".dagManager.heartbeat-%s";
   // Default job start SLA time if configured, measured in minutes. Default is 
10 minutes
   private static final String JOB_START_SLA_TIME = DAG_MANAGER_PREFIX + 
ConfigurationKeys.GOBBLIN_JOB_START_SLA_TIME;
   private static final String JOB_START_SLA_UNITS = DAG_MANAGER_PREFIX + 
ConfigurationKeys.GOBBLIN_JOB_START_SLA_TIME_UNIT;

Reply via email to