diff --git a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/ExecuteStatement.scala b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/ExecuteStatement.scala index da4cfc6c4..492330252 100644 --- a/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/ExecuteStatement.scala +++ b/kyuubi-server/src/main/scala/org/apache/kyuubi/operation/ExecuteStatement.scala @@ -69,6 +69,7 @@ class ExecuteStatement( // in thrift protocol, in sync mode, we cannot distinguish between long-run query and // engine crash without response before socket read timeout. _remoteOpHandle = client.executeStatement(statement, true, queryTimeout) + setHasResultSet(_remoteOpHandle.isHasResultSet) } catch onError() }