Skip to content

Commit

Permalink
minor updates between seq conversion
Browse files Browse the repository at this point in the history
Signed-off-by: cindyyuanjiang <[email protected]>
  • Loading branch information
cindyyuanjiang committed Dec 24, 2024
1 parent b97e2db commit 631b9c0
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -400,7 +400,7 @@ class AppSQLPlanAnalyzer(app: AppBase, appIndex: Int) extends AppAnalysisBase(ap
*/
def generateIODiagnosticAccums(): Seq[IODiagnosticResult] = {
// Transform the diagnostic metrics map into a sequence of results
IODiagnosticMetricsMap.toSeq.flatMap { case ((sqlId, nodeId), sqlAccums) =>
IODiagnosticMetricsMap.flatMap { case ((sqlId, nodeId), sqlAccums) =>
// Process each stage ID and compute diagnostic results
val stageIds = sqlAccums.head.stageIds
stageIds.flatMap { stageId =>
Expand Down Expand Up @@ -459,7 +459,7 @@ class AppSQLPlanAnalyzer(app: AppBase, appIndex: Int) extends AppAnalysisBase(ap
metricNameToStatistics(GPU_DECODE_TIME_METRIC_KEY)))
}
}
}.toSeq
}(breakOut)
}

/**
Expand Down

0 comments on commit 631b9c0

Please sign in to comment.