This is an automated email from the ASF dual-hosted git repository.
yao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-kyuubi.git
The following commit(s) were added to refs/heads/master by this push:
new 0798a07 [KYUUBI #816] [KYUUBI 813] Fix requestTimeoutUnit in
FrontendService
0798a07 is described below
commit 0798a07612a734d40f538fc6478fab0a12e0953d
Author: wuchunfu <[email protected]>
AuthorDate: Fri Jul 16 12:45:57 2021 +0800
[KYUUBI #816] [KYUUBI 813] Fix requestTimeoutUnit in FrontendService
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 <[email protected]>
Signed-off-by: Kent Yao <[email protected]>
(cherry picked from commit 0a87a254f726bdf6835274efa1e0df2fd028f2ed)
Signed-off-by: Kent Yao <[email protected]>
---
.../src/main/scala/org/apache/kyuubi/service/FrontendService.scala | 2 +-
.../main/scala/org/apache/kyuubi/client/KyuubiSyncThriftClient.scala | 5 +++++
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git
a/kyuubi-common/src/main/scala/org/apache/kyuubi/service/FrontendService.scala
b/kyuubi-common/src/main/scala/org/apache/kyuubi/service/FrontendService.scala
index ec0c230..afeb33d 100644
---
a/kyuubi-common/src/main/scala/org/apache/kyuubi/service/FrontendService.scala
+++
b/kyuubi-common/src/main/scala/org/apache/kyuubi/service/FrontendService.scala
@@ -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)
diff --git
a/kyuubi-main/src/main/scala/org/apache/kyuubi/client/KyuubiSyncThriftClient.scala
b/kyuubi-main/src/main/scala/org/apache/kyuubi/client/KyuubiSyncThriftClient.scala
new file mode 100644
index 0000000..3b05248
--- /dev/null
+++
b/kyuubi-main/src/main/scala/org/apache/kyuubi/client/KyuubiSyncThriftClient.scala
@@ -0,0 +1,5 @@
+package org.apache.kyuubi.client
+
+class KyuubiSyncThriftClient {
+
+}