apache/kyuubi
1
0
Fork 0
Code Issues Pull Requests Actions 5 Packages Projects Releases Wiki Activity

[KYUUBI #816] [KYUUBI 813] Fix requestTimeoutUnit in FrontendService

Browse Source 
Fix requestTimeoutUnit in FrontendService #813

### _How was this patch tested?_
- [ ] Add some test cases that check the changes thoroughly including negative and positive cases if possible

- [ ] Add screenshots for manual tests if appropriate

- [ ] [Run test](https://kyuubi.readthedocs.io/en/latest/tools/testing.html#running-tests) locally before make a pull request

Closes #816 from wuchunfu/813.

Closes #816

d15797ca [wuchunfu] [KYUUBI 813] Fix requestTimeoutUnit in FrontendService

Authored-by: wuchunfu <319355703@qq.com>
Signed-off-by: Kent Yao <yao@apache.org>
This commit is contained in:
wuchunfu 2021-07-16 12:45:57 +08:00 committed by Kent Yao
parent 0e5bec78ff
commit 0a87a254f7
No known key found for this signature in database
GPG Key ID: F7051850A0AF904D
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
kyuubi-common/src/main/scala/org/apache/kyuubi/service/FrontendService.scala
View File

@ -88,7 +88,7 @@ class FrontendService private (name: String, be: BackendService, oomHook: Runnab
.protocolFactory(new TBinaryProtocol.Factory)
.inputProtocolFactory(
new TBinaryProtocol.Factory(true, true, maxMessageSize, maxMessageSize))
.requestTimeout(requestTimeout).requestTimeoutUnit(TimeUnit.SECONDS)
.requestTimeout(requestTimeout).requestTimeoutUnit(TimeUnit.MILLISECONDS)
.beBackoffSlotLength(beBackoffSlotLength)
.beBackoffSlotLengthUnit(TimeUnit.MILLISECONDS)
.executorService(executor)

5
kyuubi-main/src/main/scala/org/apache/kyuubi/client/KyuubiSyncThriftClient.scala Normal file
View File

@ -0,0 +1,5 @@
package org.apache.kyuubi.client
class KyuubiSyncThriftClient {
}