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;