toLocalIterator

2018-03-20 16:56:12 +08:00 · 2018-03-20 16:56:12 +08:00 · 9ddabe0acf
commit 9ddabe0acf
parent ce7a18a64d
1 changed files with 1 additions and 1 deletions
--- a/src/main/scala/yaooqinn/kyuubi/operation/KyuubiOperation.scala
+++ b/src/main/scala/yaooqinn/kyuubi/operation/KyuubiOperation.scala
@ -383,7 +383,7 @@ class KyuubiOperation(session: KyuubiSession, statement: String) extends Logging
        _.onStatementParsed(statementId, result.queryExecution.toString())
      }
      debug(result.queryExecution.toString())
-      iter = result.collect().iterator
+      iter = result.toLocalIterator().asScala
      dataTypes = result.queryExecution.analyzed.output.map(_.dataType).toArray
      setState(FINISHED)
      KyuubiServerMonitor.getListener(session.getUserName).foreach(_.onStatementFinish(statementId))