bowenliang123 commented on issue #5392:
URL: https://github.com/apache/kyuubi/issues/5392#issuecomment-1754681773
It's suspicious that the loop inside `ExecuteStatement` for status checks,
1. it tries to fetch query log first (`fetchQueryLog`)
2. and then poll the operation state for query
In step one, it uses a `KyuubiSyncThriftClient` instance to connect and
query from the engine instance.
The a `KyuubiSyncThriftClient` instance is created with no socket timeout
(set to 0 manually),
KyuubiSessionImpl:
```
_client = KyuubiSyncThriftClient.createClient(user, passwd,
host, port, sessionConf)
```
KyuubiSyncThriftClient:
```
val tProtocol = createTProtocol(user, passwd, host, port, 0,
loginTimeout)
```
With no socket timeout set, it may block the timeout state checks and
therefore the statement is not able to do the step 2 and jammed at step 1.
--
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]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
