Fixing a minor bug in monitoring paths
@@ -162,7 +162,7 @@ public class MonitoringUtil {
}
public static String getJobNameByJobId(CuratorFramework curatorClient, String jobId) throws Exception {
- String path = REGISTRY + jobId + JOB_NAME;
+ String path = MONITORING + jobId + JOB_NAME;
if (curatorClient.checkExists().forPath(path) != null) {
byte[] gatewayBytes = curatorClient.getData().forPath(path);
return new String(gatewayBytes);
@@ -172,7 +172,7 @@ public class MonitoringUtil {
}
public static String getJobIdByJobName(CuratorFramework curatorClient, String jobName) throws Exception {
- String path = REGISTRY + jobName + JOB_ID;
+ String path = MONITORING + jobName + JOB_ID;
if (curatorClient.checkExists().forPath(path) != null) {
byte[] gatewayBytes = curatorClient.getData().forPath(path);
return new String(gatewayBytes);
