[KYUUBI #1961] Upgrade hive-service-rpc to 3.1.2

### _Why are the changes needed?_

Upgrade `hive-service-rpc` to 3.1.2.

### _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

- [x] [Run test](https://kyuubi.apache.org/docs/latest/develop_tools/testing.html#running-tests) locally before make a pull request

Closes #2031 from SteNicholas/KYUUBI-1961.

Closes #1961

88c29557 [SteNicholas] [KYUUBI #1961] Upgrade hive-service-rpc to 3.1.2

Authored-by: SteNicholas <programgeek@163.com>
Signed-off-by: Kent Yao <yao@apache.org>
This commit is contained in:
SteNicholas 2022-03-04 18:41:34 +08:00 committed by Kent Yao
parent faa2dd4122
commit ce8462705f
No known key found for this signature in database
GPG Key ID: F7051850A0AF904D
4 changed files with 17 additions and 2 deletions

View File

@ -28,7 +28,7 @@ hadoop-client-runtime/3.3.2//hadoop-client-runtime-3.3.2.jar
hive-common/2.3.9//hive-common-2.3.9.jar
hive-metastore/2.3.9//hive-metastore-2.3.9.jar
hive-serde/2.3.9//hive-serde-2.3.9.jar
hive-service-rpc/2.3.9//hive-service-rpc-2.3.9.jar
hive-service-rpc/3.1.2//hive-service-rpc-3.1.2.jar
hive-shims-0.23/2.3.9//hive-shims-0.23-2.3.9.jar
hive-shims-common/2.3.9//hive-shims-common-2.3.9.jar
hk2-api/2.6.1//hk2-api-2.6.1.jar

View File

@ -493,6 +493,19 @@ abstract class TFrontendService(name: String)
resp
}
override def GetQueryId(req: TGetQueryIdReq): TGetQueryIdResp = {
debug(req.toString)
val resp = new TGetQueryIdResp
resp
}
override def SetClientInfo(req: TSetClientInfoReq): TSetClientInfoResp = {
debug(req.toString)
val resp = new TSetClientInfoResp
resp.setStatus(KyuubiSQLException.featureNotSupported().toTStatus)
resp
}
protected def isServer(): Boolean = false
class FeTServerEventHandler extends TServerEventHandler {

View File

@ -178,5 +178,6 @@ object MySQLDataType {
case TTypeId.CHAR_TYPE => STRING
case TTypeId.INTERVAL_YEAR_MONTH_TYPE => VAR_STRING // not exactly match, fallback
case TTypeId.INTERVAL_DAY_TIME_TYPE => VAR_STRING // not exactly match, fallback
case TTypeId.TIMESTAMPLOCALTZ_TYPE => TIMESTAMP
}
}

View File

@ -112,6 +112,7 @@
<guava.failureaccess.version>1.0.1</guava.failureaccess.version>
<hadoop.version>3.3.2</hadoop.version>
<hive.version>2.3.9</hive.version>
<hive.service.rpc.version>3.1.2</hive.service.rpc.version>
<hudi.version>0.10.0</hudi.version>
<iceberg.name>iceberg-spark-runtime-3.2_${scala.binary.version}</iceberg.name>
<iceberg.version>0.13.1</iceberg.version>
@ -557,7 +558,7 @@
<dependency>
<groupId>org.apache.hive</groupId>
<artifactId>hive-service-rpc</artifactId>
<version>${hive.version}</version>
<version>${hive.service.rpc.version}</version>
<exclusions>
<exclusion>
<groupId>*</groupId>