Browse Source

Add task prepare metrics

3.0.0/version-upgrade
Wenjun Ruan 2 years ago
parent
commit
04c47034d4
  1. 28
      dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/metrics/TaskMetrics.java

28
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/metrics/TaskMetrics.java

@ -30,57 +30,57 @@ public final class TaskMetrics {
} }
private static final Counter TASK_SUBMIT_COUNTER = private static final Counter TASK_SUBMIT_COUNTER =
Counter.builder("dolphinscheduler_task_submit_count") Counter.builder("ds.task.submit.count")
.description("Task submit total count") .description("Task submit total count")
.register(Metrics.globalRegistry); .register(Metrics.globalRegistry);
private static final Counter TASK_FINISH_COUNTER = private static final Counter TASK_FINISH_COUNTER =
Counter.builder("dolphinscheduler_task_finish_count") Counter.builder("ds.task.finish.count")
.description("Task finish total count") .description("Task finish total count")
.register(Metrics.globalRegistry); .register(Metrics.globalRegistry);
private static final Counter TASK_SUCCESS_COUNTER = private static final Counter TASK_SUCCESS_COUNTER =
Counter.builder("dolphinscheduler_task_success_count") Counter.builder("ds.task.success.count")
.description("Task success total count") .description("Task success total count")
.register(Metrics.globalRegistry); .register(Metrics.globalRegistry);
private static final Counter TASK_FAILURE_COUNTER = private static final Counter TASK_FAILURE_COUNTER =
Counter.builder("dolphinscheduler_task_failure_count") Counter.builder("ds.task.failure.count")
.description("Task failure total count") .description("Task failure total count")
.register(Metrics.globalRegistry); .register(Metrics.globalRegistry);
private static final Counter TASK_TIMEOUT_COUNTER = private static final Counter TASK_TIMEOUT_COUNTER =
Counter.builder("dolphinscheduler_task_timeout_count") Counter.builder("ds.task.timeout.count")
.description("Task timeout total count") .description("Task timeout total count")
.register(Metrics.globalRegistry); .register(Metrics.globalRegistry);
private static final Counter TASK_RETRY_COUNTER = private static final Counter TASK_RETRY_COUNTER =
Counter.builder("dolphinscheduler_task_retry_count") Counter.builder("ds.task.retry.count")
.description("Task retry total count") .description("Task retry total count")
.register(Metrics.globalRegistry); .register(Metrics.globalRegistry);
private static final Counter TASK_STOP_COUNTER = private static final Counter TASK_STOP_COUNTER =
Counter.builder("dolphinscheduler_task_stop_count") Counter.builder("ds.task.stop.count")
.description("Task stop total count") .description("Task stop total count")
.register(Metrics.globalRegistry); .register(Metrics.globalRegistry);
private static final Counter TASK_FAILOVER_COUNTER = private static final Counter TASK_FAILOVER_COUNTER =
Counter.builder("dolphinscheduler_task_failover_count") Counter.builder("ds.task.failover.count")
.description("Task failover total count") .description("Task failover total count")
.register(Metrics.globalRegistry); .register(Metrics.globalRegistry);
private static final Counter TASK_DISPATCH_COUNTER = private static final Counter TASK_DISPATCH_COUNTER =
Counter.builder("dolphinscheduler_task_dispatch_count") Counter.builder("ds.task.dispatch.count")
.description("Task dispatch count") .description("Task dispatch count")
.register(Metrics.globalRegistry); .register(Metrics.globalRegistry);
private static final Counter TASK_DISPATCHER_FAILED = private static final Counter TASK_DISPATCHER_FAILED =
Counter.builder("dolphinscheduler_task_dispatch_failed_count") Counter.builder("ds.task.dispatch.failure.count")
.description("Task dispatch failed count") .description("Task dispatch failed count")
.register(Metrics.globalRegistry); .register(Metrics.globalRegistry);
private static final Counter TASK_DISPATCH_ERROR = private static final Counter TASK_DISPATCH_ERROR =
Counter.builder("dolphinscheduler_task_dispatch_error_count") Counter.builder("ds.task.dispatch.error.count")
.description("Task dispatch error") .description("Task dispatch error")
.register(Metrics.globalRegistry); .register(Metrics.globalRegistry);
@ -88,9 +88,9 @@ public final class TaskMetrics {
TASK_SUBMIT_COUNTER.increment(); TASK_SUBMIT_COUNTER.increment();
} }
public synchronized static void registerTaskRunning(Supplier<Number> consumer) { public synchronized static void registerTaskPrepared(Supplier<Number> consumer) {
Gauge.builder("dolphinscheduler_task_running_gauge", consumer) Gauge.builder("ds.task.prepared", consumer)
.description("Task running count") .description("Task prepared count")
.register(Metrics.globalRegistry); .register(Metrics.globalRegistry);
} }

Loading…
Cancel
Save