diff --git a/kyuubi-main/src/main/scala/org/apache/kyuubi/operation/ExecuteStatement.scala b/kyuubi-main/src/main/scala/org/apache/kyuubi/operation/ExecuteStatement.scala index 7292a1353..798f5f047 100644 --- a/kyuubi-main/src/main/scala/org/apache/kyuubi/operation/ExecuteStatement.scala +++ b/kyuubi-main/src/main/scala/org/apache/kyuubi/operation/ExecuteStatement.scala @@ -84,7 +84,7 @@ class ExecuteStatement( var statusResp = client.GetOperationStatus(statusReq) var isComplete = false while (!isComplete) { - getQueryLog() + fetchQueryLog() verifyTStatus(statusResp.getStatus) val remoteState = statusResp.getOperationState info(s"Query[$statementId] in ${remoteState.name()}") @@ -118,10 +118,10 @@ class ExecuteStatement( } } // see if anymore log could be fetched - getQueryLog() + fetchQueryLog() } catch onError() - private def getQueryLog(): Unit = { + private def fetchQueryLog(): Unit = { getOperationLog.foreach { logger => try { val resp = client.FetchResults(fetchLogReq)