azkaban-memoizeit

Fixing a bug in NumQueuedFlowMetric

12/18/2014 7:07:54 AM

Gaurav Aggarwal

Commit: c0cea3c

Tree: 8dfdf0d

Parents: c3a0c0a

Changes

azkaban-execserver/src/main/java/azkaban/execapp/metric/NumQueuedFlowMetric.java 2(+1 -1)

Details

azkaban-execserver/src/main/java/azkaban/execapp/metric/NumQueuedFlowMetric.java 2(+1 -1)

diff --git a/azkaban-execserver/src/main/java/azkaban/execapp/metric/NumQueuedFlowMetric.java b/azkaban-execserver/src/main/java/azkaban/execapp/metric/NumQueuedFlowMetric.java
index 5036078..6ecc385 100644
--- a/azkaban-execserver/src/main/java/azkaban/execapp/metric/NumQueuedFlowMetric.java
+++ b/azkaban-execserver/src/main/java/azkaban/execapp/metric/NumQueuedFlowMetric.java
@@ -21,7 +21,7 @@ import azkaban.metric.MetricReportManager;
 import azkaban.metric.TimeBasedReportingMetric;
 
 public class NumQueuedFlowMetric extends TimeBasedReportingMetric<Integer> {
-  public static final String NUM_QUEUED_FLOW_METRIC_NAME = "NumRunningFlowMetric";
+  public static final String NUM_QUEUED_FLOW_METRIC_NAME = "NumQueuedFlowMetric";
   private static final String NUM_QUEUED_FLOW_METRIC_TYPE = "uint16";
 
   private FlowRunnerManager flowManager;