yaooqinn commented on a change in pull request #1391:
URL: https://github.com/apache/incubator-kyuubi/pull/1391#discussion_r750036802
##########
File path:
kyuubi-server/src/main/scala/org/apache/kyuubi/operation/ExecuteStatement.scala
##########
@@ -77,66 +78,71 @@ class ExecuteStatement(
} catch onError()
}
- private def waitStatementComplete(): Unit = try {
- setState(OperationState.RUNNING)
- var statusResp: TGetOperationStatusResp = null
- var currentAttempts = 0
-
- def fetchOperationStatusWithRetry(): Unit = {
- try {
- statusResp = client.getOperationStatus(_remoteOpHandle)
- currentAttempts = 0 // reset attempts whenever get touch with engine
again
- } catch {
- case e: TException if currentAttempts >= maxStatusPollOnFailure =>
- error(s"Failed to get ${session.user}'s query[$getHandle] status
after" +
- s" $maxStatusPollOnFailure times, aborting", e)
- throw e
- case e: TException =>
- currentAttempts += 1
- warn(s"Failed to get ${session.user}'s query[$getHandle] status" +
- s" ($currentAttempts / $maxStatusPollOnFailure)", e)
- Thread.sleep(100)
+ private def waitStatementComplete(): Unit =
+ try {
Review comment:
unnecessary newline to me
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
