[FLINK-29209] Fail to connect HiveServer endpoint with TProtocolException

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Not A Problem
• Affects Version/s: 1.16.0
• Fix Version/s: 1.16.0
• Component/s: Connectors / Hive
• Assignee: Unassigned
• Reporter: luoyuxia
• Created: 06/Sep/22 10:06
• Updated: 19/Sep/22 12:14
• Resolved: 19/Sep/22 12:14

Description

When I try to connect HiveServer endpoint with some BI tools like Apache SuperSet / FineBI / MetaBase, it fails to connect with the following exception:

2022-09-05 20:12:36,179 ERROR org.apache.thrift.server.TThreadPoolServer                   [] - Thrift error occurred during processing of message.
org.apache.thrift.protocol.TProtocolException: Missing version in readMessageBegin, old client?
    at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:228) ~[flink-sql-connector-hive-2.3.9_2.12-1.16-SNAPSHOT.jar:1.16-SNAPSHOT]
    at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:27) ~[flink-sql-connector-hive-2.3.9_2.12-1.16-SNAPSHOT.jar:1.16-SNAPSHOT]
    at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:286) [flink-sql-connector-hive-2.3.9_2.12-1.16-SNAPSHOT.jar:1.16-SNAPSHOT]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_332]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_332]
    at java.lang.Thread.run(Thread.java:750) [?:1.8.0_332] 

The jdbc url is "jdbc:hive2://host:port/default;auth=noSasl".

But then I try to connect Hive's own HiveServer, the jdbc url is "jdbc:hive2://host:port/default",  it works well.

Seems we need extra configuration or adaption to connect to Flink's HiveServer endpoint 

Issue Links

• is a child of: FLINK-28954 Release Testing: Verify FLIP-223 HiveServer2 Endpoint