Skip to content

Commit db0e298

Browse files
fix the long to int parse bug.
1 parent f0db900 commit db0e298

File tree

1 file changed

+2
-2
lines changed
  • streamis-jobmanager/streamis-job-manager/streamis-job-manager-service/src/main/scala/com/webank/wedatasphere/streamis/jobmanager/manager/transform/parser

1 file changed

+2
-2
lines changed

streamis-jobmanager/streamis-job-manager/streamis-job-manager-service/src/main/scala/com/webank/wedatasphere/streamis/jobmanager/manager/transform/parser/SparkTaskMetricsParser.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -64,9 +64,9 @@ class SparkTaskMetricsParser extends AbstractTaskMetricsParser {
6464
realTimeTrafficDTO.setTransformKey("processing")
6565
realTimeTrafficDTO.setSinkKey(metricsMap.getOrDefault("sink", "<Unknown>").asInstanceOf[String])
6666
val sinkSpeed = if (batchMetric.containsKey("totalDelay") && batchMetric.get("totalDelay") != null)
67-
Utils.msDurationToString(batchMetric.get("totalDelay").asInstanceOf[Long]) + " totalDelay"
67+
Utils.msDurationToString(batchMetric.get("totalDelay").toString.toInt) + " totalDelay"
6868
else if (batchMetric.containsKey("taskExecuteTime") && batchMetric.get("taskExecuteTime") != null)
69-
Utils.msDurationToString(batchMetric.get("taskExecuteTime").asInstanceOf[Long]) + " executeTime(Last Batch)"
69+
Utils.msDurationToString(batchMetric.get("taskExecuteTime").toString.toInt) + " executeTime(Last Batch)"
7070
else "<Unknown>"
7171
realTimeTrafficDTO.setSinkSpeed(sinkSpeed)
7272
case _ =>

0 commit comments

Comments
 (0)