Skip to content

Commit f0db900

Browse files
fix the compilation bug.
1 parent df32413 commit f0db900

File tree

1 file changed

+1
-1
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

+1
-1
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: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ class SparkTaskMetricsParser extends AbstractTaskMetricsParser {
2222
dataNumberDTOS: util.List[JobDetailsVo.DataNumberDTO],
2323
loadConditionDTOs: util.List[JobDetailsVo.LoadConditionDTO],
2424
realTimeTrafficDTOS: util.List[JobDetailsVo.RealTimeTrafficDTO]): Unit = {
25-
val addDataNumberDTO: String => () = key => {
25+
val addDataNumberDTO: String => Unit = key => {
2626
val batch = new JobDetailsVo.DataNumberDTO
2727
batch.setDataName(key)
2828
batch.setDataNumber(metricsMap.get(key).toString.toInt)

0 commit comments

Comments
 (0)