Hi, 请教下
我尝试使用sql-client连接hive, hive正常, 使用beeline -u jdbc:hive2://x.x.x.x:10000 可以正常连接
sql-client-defaults.yaml配置内容:
tables: []
functions: []
catalogs:
- name: myhive
type: hive
hive-conf-dir: /home/hive/flink-1.11.1/conf
default-database: default
execution:
planner: blink
type: streaming
time-characteristic: event-time
periodic-watermarks-interval: 200
result-mode: table
max-table-result-rows: 1000000
parallelism: 1
max-parallelism: 128
min-idle-state-retention: 0
max-idle-state-retention: 0
restart-strategy:
type: fallback
deployment:
response-timeout: 5000
gateway-address: ""
gateway-port: 0
然后启动sql-client报错
$./bin/sql-client.sh embedded
最后的报错信息:
Exception in thread "main" org.apache.flink.table.client.SqlClientException:
Unexpected exception. This is a bug. Please consider filing an issue.
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:213)
Caused by: org.apache.flink.table.client.gateway.SqlExecutionException: Could
not create execution context.
at
org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:870)
at
org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:227)
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:108)
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
Caused by: org.apache.flink.table.catalog.exceptions.CatalogException: Failed
to determine whether database default exists or not
at
org.apache.flink.table.catalog.hive.HiveCatalog.databaseExists(HiveCatalog.java:335)
at org.apache.flink.table.catalog.hive.HiveCatalog.open(HiveCatalog.java:227)
at
org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:191)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.registerCatalog(TableEnvironmentImpl.java:337)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$null$5(ExecutionContext.java:627)
at java.util.HashMap.forEach(HashMap.java:1289)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$initializeCatalogs$6(ExecutionContext.java:625)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.wrapClassLoader(ExecutionContext.java:264)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:624)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:523)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:183)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:136)
at
org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:859)
... 3 more
Caused by: org.apache.thrift.transport.TTransportException
at
org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:86)
at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:429)
at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:318)
at
org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:219)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:77)
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_get_database(ThriftHiveMetastore.java:1135)
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.get_database(ThriftHiveMetastore.java:1122)
at
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.getDatabase(HiveMetaStoreClient.java:1511)
at
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.getDatabase(HiveMetaStoreClient.java:1506)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:208)
at com.sun.proxy.$Proxy28.getDatabase(Unknown Source)
at
org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.getDatabase(HiveMetastoreClientWrapper.java:107)
at
org.apache.flink.table.catalog.hive.HiveCatalog.databaseExists(HiveCatalog.java:330)
... 15 more
附录完整错误信息:
Searching for '/home/hive/flink-1.11.1/conf/sql-client-defaults.yaml'...found.
Reading default environment from:
file:/home/hive/flink-1.11.1/conf/sql-client-defaults.yaml
No session environment specified.
2020-10-27 09:48:14,533 INFO org.apache.hadoop.hive.conf.HiveConf
[] - Found configuration file
file:/home/hive/flink-1.11.1/conf/hive-site.xml
2020-10-27 09:48:15,144 INFO
org.apache.hadoop.hive.metastore.HiveMetaStoreClient [] - Trying to
connect to metastore with URI thrift://x.x.x.x:10000
2020-10-27 09:48:15,168 INFO
org.apache.hadoop.hive.metastore.HiveMetaStoreClient [] - Opened a
connection to metastore, current connections: 1
2020-10-27 09:48:15,240 WARN
org.apache.hadoop.hive.metastore.HiveMetaStoreClient [] - set_ugi() not
successful, Likely cause: new client talking to old server. Continuing without
it.
org.apache.thrift.transport.TTransportException: null
at
org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:86)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.thrift.protocol.TBinaryProtocol.readStringBody(TBinaryProtocol.java:380)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:230)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:77)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_set_ugi(ThriftHiveMetastore.java:4787)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.set_ugi(ThriftHiveMetastore.java:4773)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.open(HiveMetaStoreClient.java:534)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.<init>(HiveMetaStoreClient.java:224)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
~[?:1.8.0_251]
at
sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
~[?:1.8.0_251]
at
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
~[?:1.8.0_251]
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
~[?:1.8.0_251]
at
org.apache.hadoop.hive.metastore.utils.JavaUtils.newInstance(JavaUtils.java:84)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.<init>(RetryingMetaStoreClient.java:95)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.getProxy(RetryingMetaStoreClient.java:148)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.getProxy(RetryingMetaStoreClient.java:104)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_251]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_251]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_251]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_251]
at
org.apache.flink.table.catalog.hive.client.HiveShimV310.getHiveMetastoreClient(HiveShimV310.java:103)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.createMetastoreClient(HiveMetastoreClientWrapper.java:240)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.<init>(HiveMetastoreClientWrapper.java:71)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.catalog.hive.client.HiveMetastoreClientFactory.create(HiveMetastoreClientFactory.java:35)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at org.apache.flink.table.catalog.hive.HiveCatalog.open(HiveCatalog.java:223)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:191)
~[flink-table_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.registerCatalog(TableEnvironmentImpl.java:337)
~[flink-table_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$null$5(ExecutionContext.java:627)
~[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at java.util.HashMap.forEach(HashMap.java:1289) ~[?:1.8.0_251]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$initializeCatalogs$6(ExecutionContext.java:625)
~[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.wrapClassLoader(ExecutionContext.java:264)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:624)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:523)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:183)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:136)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:859)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:227)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:108)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
2020-10-27 09:48:15,247 INFO
org.apache.hadoop.hive.metastore.HiveMetaStoreClient [] - Connected to
metastore.
2020-10-27 09:48:15,247 INFO
org.apache.hadoop.hive.metastore.RetryingMetaStoreClient [] -
RetryingMetaStoreClient proxy=class
org.apache.hadoop.hive.metastore.HiveMetaStoreClient ugi=hive (auth:SIMPLE)
retries=1 delay=1 lifetime=0
2020-10-27 09:48:15,364 WARN
org.apache.hadoop.hive.metastore.RetryingMetaStoreClient [] -
MetaStoreClient lost connection. Attempting to reconnect (1 of 1) after 1s.
getDatabase
org.apache.thrift.transport.TTransportException: null
at
org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:86)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:429)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:318)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:219)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:77)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_get_database(ThriftHiveMetastore.java:1135)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.get_database(ThriftHiveMetastore.java:1122)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.getDatabase(HiveMetaStoreClient.java:1511)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.getDatabase(HiveMetaStoreClient.java:1506)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_251]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_251]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_251]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_251]
at
org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:208)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at com.sun.proxy.$Proxy28.getDatabase(Unknown Source) ~[?:?]
at
org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.getDatabase(HiveMetastoreClientWrapper.java:107)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.catalog.hive.HiveCatalog.databaseExists(HiveCatalog.java:330)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at org.apache.flink.table.catalog.hive.HiveCatalog.open(HiveCatalog.java:227)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:191)
~[flink-table_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.registerCatalog(TableEnvironmentImpl.java:337)
~[flink-table_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$null$5(ExecutionContext.java:627)
~[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at java.util.HashMap.forEach(HashMap.java:1289) ~[?:1.8.0_251]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$initializeCatalogs$6(ExecutionContext.java:625)
~[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.wrapClassLoader(ExecutionContext.java:264)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:624)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:523)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:183)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:136)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:859)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:227)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:108)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
2020-10-27 09:48:16,365 INFO
org.apache.hadoop.hive.metastore.RetryingMetaStoreClient [] -
RetryingMetaStoreClient trying reconnect as hive (auth:SIMPLE)
2020-10-27 09:48:16,375 INFO
org.apache.hadoop.hive.metastore.HiveMetaStoreClient [] - Closed a
connection to metastore, current connections: 0
2020-10-27 09:48:16,375 INFO
org.apache.hadoop.hive.metastore.HiveMetaStoreClient [] - Trying to
connect to metastore with URI thrift://x.x.x.x:10000
2020-10-27 09:48:16,376 INFO
org.apache.hadoop.hive.metastore.HiveMetaStoreClient [] - Opened a
connection to metastore, current connections: 1
2020-10-27 09:48:16,436 WARN
org.apache.hadoop.hive.metastore.HiveMetaStoreClient [] - set_ugi() not
successful, Likely cause: new client talking to old server. Continuing without
it.
org.apache.thrift.transport.TTransportException: null
at
org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:86)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.thrift.protocol.TBinaryProtocol.readStringBody(TBinaryProtocol.java:380)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:230)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:77)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_set_ugi(ThriftHiveMetastore.java:4787)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.set_ugi(ThriftHiveMetastore.java:4773)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.open(HiveMetaStoreClient.java:534)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.reconnect(HiveMetaStoreClient.java:379)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.hadoop.hive.metastore.RetryingMetaStoreClient$1.run(RetryingMetaStoreClient.java:187)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_251]
at javax.security.auth.Subject.doAs(Subject.java:422) ~[?:1.8.0_251]
at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1836)
~[flink-shaded-hadoop-2-uber-2.8.3-10.0.jar:2.8.3-10.0]
at
org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:183)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at com.sun.proxy.$Proxy28.getDatabase(Unknown Source) ~[?:?]
at
org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.getDatabase(HiveMetastoreClientWrapper.java:107)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.catalog.hive.HiveCatalog.databaseExists(HiveCatalog.java:330)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at org.apache.flink.table.catalog.hive.HiveCatalog.open(HiveCatalog.java:227)
~[flink-sql-connector-hive-3.1.2_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:191)
~[flink-table_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.registerCatalog(TableEnvironmentImpl.java:337)
~[flink-table_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$null$5(ExecutionContext.java:627)
~[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at java.util.HashMap.forEach(HashMap.java:1289) ~[?:1.8.0_251]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$initializeCatalogs$6(ExecutionContext.java:625)
~[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.wrapClassLoader(ExecutionContext.java:264)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:624)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:523)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:183)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:136)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:859)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at
org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:227)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:108)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
[flink-sql-client_2.12-1.11.1.jar:1.11.1]
2020-10-27 09:48:16,438 INFO
org.apache.hadoop.hive.metastore.HiveMetaStoreClient [] - Connected to
metastore.
Exception in thread "main" org.apache.flink.table.client.SqlClientException:
Unexpected exception. This is a bug. Please consider filing an issue.
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:213)
Caused by: org.apache.flink.table.client.gateway.SqlExecutionException: Could
not create execution context.
at
org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:870)
at
org.apache.flink.table.client.gateway.local.LocalExecutor.openSession(LocalExecutor.java:227)
at org.apache.flink.table.client.SqlClient.start(SqlClient.java:108)
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
Caused by: org.apache.flink.table.catalog.exceptions.CatalogException: Failed
to determine whether database default exists or not
at
org.apache.flink.table.catalog.hive.HiveCatalog.databaseExists(HiveCatalog.java:335)
at org.apache.flink.table.catalog.hive.HiveCatalog.open(HiveCatalog.java:227)
at
org.apache.flink.table.catalog.CatalogManager.registerCatalog(CatalogManager.java:191)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.registerCatalog(TableEnvironmentImpl.java:337)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$null$5(ExecutionContext.java:627)
at java.util.HashMap.forEach(HashMap.java:1289)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$initializeCatalogs$6(ExecutionContext.java:625)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.wrapClassLoader(ExecutionContext.java:264)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.initializeCatalogs(ExecutionContext.java:624)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.initializeTableEnvironment(ExecutionContext.java:523)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:183)
at
org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:136)
at
org.apache.flink.table.client.gateway.local.ExecutionContext$Builder.build(ExecutionContext.java:859)
... 3 more
Caused by: org.apache.thrift.transport.TTransportException
at
org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:86)
at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:429)
at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:318)
at
org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:219)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:77)
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_get_database(ThriftHiveMetastore.java:1135)
at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.get_database(ThriftHiveMetastore.java:1122)
at
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.getDatabase(HiveMetaStoreClient.java:1511)
at
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.getDatabase(HiveMetaStoreClient.java:1506)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:208)
at com.sun.proxy.$Proxy28.getDatabase(Unknown Source)
at
org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.getDatabase(HiveMetastoreClientWrapper.java:107)
at
org.apache.flink.table.catalog.hive.HiveCatalog.databaseExists(HiveCatalog.java:330)
... 15 more
谢谢!
