#000: Review comment fix - Generation of metrics

Sanketika-Obsrv · Jan 3, 2025 · 6ae728a · 6ae728a
1 parent 7f69c11
commit 6ae728a
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...e/hudi-connector/src/main/scala/org/sunbird/obsrv/function/RowDataConverterFunction.scala b/...e/hudi-connector/src/main/scala/org/sunbird/obsrv/function/RowDataConverterFunction.scala
@@ -40,8 +40,8 @@ class RowDataConverterFunction(config: HudiConnectorConfig, datasetId: String) e
     hudiSchemaParser = new HudiSchemaParser()
 
     // Register Flink metrics for inputEventCount and failedEventCount
-    inputEventCount = getRuntimeContext.getMetricGroup.counter("inputEventCount")
-    failedEventCount = getRuntimeContext.getMetricGroup.counter("failedEventCount")
+    inputEventCount = getRuntimeContext.getMetricGroup.counter("inputEventCountdata")
+    failedEventCount = getRuntimeContext.getMetricGroup.counter("failedEventCountdata")
   }
 
   override def map(event: MMap[String, AnyRef]): RowData = {
@@ -79,8 +79,8 @@ class RowDataConverterFunction(config: HudiConnectorConfig, datasetId: String) e
   // Custom method to retrieve the metric values (e.g., for exposing them in a monitoring system)
   def getMetrics: Map[String, Long] = {
     Map(
-      "inputEventCount" -> inputEventCount.getCount,
-      "failedEventCount" -> failedEventCount.getCount
+      "inputEventCountdata" -> inputEventCount.getCount,
+      "failedEventCountdata" -> failedEventCount.getCount
     )
   }
 }