diff --git a/externals/kyuubi-trino-engine/src/main/scala/org/apache/kyuubi/engine/trino/TrinoProgressMonitor.scala b/externals/kyuubi-trino-engine/src/main/scala/org/apache/kyuubi/engine/trino/TrinoProgressMonitor.scala
index 5328f092ec9..466944e39c7 100644
--- a/externals/kyuubi-trino-engine/src/main/scala/org/apache/kyuubi/engine/trino/TrinoProgressMonitor.scala
+++ b/externals/kyuubi-trino-engine/src/main/scala/org/apache/kyuubi/engine/trino/TrinoProgressMonitor.scala
@@ -49,9 +49,9 @@ class TrinoProgressMonitor(trino: StatementClient) {
           stage.getFailedTasks)
         stages.append((TrinoStage(stageId), stageProgress))
         val subStages = asScalaBuffer(stage.getSubStages)
-        stageQueue.enqueue(subStages: _*)
+        stageQueue ++= subStages.toSeq
       }
-      SortedMap(stages: _*)
+      SortedMap(stages.toSeq: _*)
     } else {
       SortedMap()
     }