Skip to content

Commit 53bba28

Browse files
committed
fix routine load metrics
1 parent ed46091 commit 53bba28

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -907,7 +907,7 @@ private void updateNumOfData(long numOfTotalRows, long numOfErrorRows, long unse
907907
MetricRepo.COUNTER_ROUTINE_LOAD_ERROR_ROWS.increase(numOfErrorRows);
908908
MetricRepo.COUNTER_ROUTINE_LOAD_RECEIVED_BYTES.increase(receivedBytes);
909909
MetricRepo.COUNTER_ROUTINE_LOAD_TASK_EXECUTE_TIME.increase(taskExecutionTime);
910-
MetricRepo.COUNTER_ROUTINE_LOAD_TASK_EXECUTE_TIME.increase(1L);
910+
MetricRepo.COUNTER_ROUTINE_LOAD_TASK_EXECUTE_COUNT.increase(1L);
911911
}
912912

913913
// check error rate

fe/fe-core/src/main/java/org/apache/doris/metric/MetricRepo.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -635,7 +635,7 @@ public Long getValue() {
635635
MetricUnit.MILLISECONDS, "task execute time of routine load");
636636
DORIS_METRIC_REGISTER.addMetrics(COUNTER_ROUTINE_LOAD_TASK_EXECUTE_TIME);
637637
COUNTER_ROUTINE_LOAD_TASK_EXECUTE_COUNT = new LongCounterMetric("routine_load_task_execute_count",
638-
MetricUnit.MILLISECONDS, "task execute count of routine load");
638+
MetricUnit.NOUNIT, "task execute count of routine load");
639639
DORIS_METRIC_REGISTER.addMetrics(COUNTER_ROUTINE_LOAD_TASK_EXECUTE_COUNT);
640640

641641
COUNTER_HIT_SQL_BLOCK_RULE = new LongCounterMetric("counter_hit_sql_block_rule", MetricUnit.ROWS,

0 commit comments

Comments
 (0)