Apache Flink 中文用户邮件列表

回复：【flink sql-client 读写 Kerberos认证的hive】

classic Classic list List threaded Threaded
♦
♦
 1 message Options
guoyb-2
Reply | Threaded
Open this post in threaded view
♦
♦
|

回复：【flink sql-client 读写 Kerberos认证的hive】

guoyb-2
好的，谢谢！



---原始邮件---
发件人: "Rui Li"<[hidden email]&gt;
发送时间: 2021年3月8日(周一) 下午5:10
收件人: "user-zh"<[hidden email]&gt;;
主题: Re: 【flink sql-client 读写 Kerberos认证的hive】


那应该就是跟https://issues.apache.org/jira/browse/FLINK-20913
&nbsp;有关了，这个issue是1.12.2修复的，可以升级一下试试。

On Mon, Mar 8, 2021 at 2:15 PM guoyb <[hidden email]&gt; wrote:

&gt; 您好！
&gt; hive.metastore.sasl.enabled 是true
&gt;
&gt;
&gt; 启动sql client的时候，可以正常读取到认证信息，并读取metastore的表名。
&gt;
&gt;
&gt; 读和写，认证就失败了。
&gt;
&gt;
&gt;
&gt; ---原始邮件---
&gt; 发件人: "Rui Li"<[hidden email]&amp;gt;
&gt; 发送时间: 2021年3月8日(周一) 中午12:12
&gt; 收件人: "user-zh"<[hidden email]&amp;gt;;
&gt; 主题: Re: 【flink sql-client 读写 Kerberos认证的hive】
&gt;
&gt;
&gt; Hi，
&gt;
&gt;
&gt; 从你发的stacktrace来看，走到了set_ugi方法说明client认为server没有开启kerberos。确认一下你HiveCatalog这边指定的hive-site.xml是否配置正确呢，像hive.metastore.sasl.enabled是不是设置成true了？
&gt;
&gt; On Sun, Mar 7, 2021 at 5:49 PM [hidden email] <[hidden email]&amp;gt;
&gt; wrote:
&gt;
&gt; &amp;gt; 环境：
&gt; &amp;gt; flink1.12.1&amp;amp;nbsp;
&gt; &amp;gt; hive2.1.0
&gt; &amp;gt; CDH6.2.0
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; 【问题描述】
&gt; &amp;gt; &amp;amp;nbsp;在没开启Kerberos认证时，可以正常读写hive表
&gt; &amp;gt; &amp;amp;nbsp;
&gt; &amp;gt; &amp;amp;nbsp;开启Kerberos认证后，
&gt; &amp;gt; &amp;amp;nbsp;启动时可以正常读取到hive metastore的元数据信息，读写不了表。
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; 【sql-client.sh embedded】
&gt; &amp;gt; Flink SQL&amp;amp;gt; show tables;
&gt; &amp;gt; dimension_table
&gt; &amp;gt; dimension_table1
&gt; &amp;gt; test
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; Flink SQL&amp;amp;gt; select * from test;
&gt; &amp;gt; [ERROR] Could not execute SQL statement. Reason:
&gt; &amp;gt; org.apache.flink.connectors.hive.FlinkHiveException: Failed to
&gt; collect all
&gt; &amp;gt; partitions from hive metaStore
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; 【完整日志
&gt; &amp;gt;
&gt; /opt/cloudera/parcels/FLINK-1.12.1-BIN-SCALA_2.11/lib/flink/log/flink-root-sql-client-cdh6.com.log】
&gt; &amp;gt;
&gt; &amp;gt; 2021-03-07 10:29:18.776 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Trying to connect to localhost/127.0.0.1:6123
&gt; &amp;gt; 2021-03-07 10:29:18.777 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address 'cdh6.com/192.168.31.10': Connection
&gt; &amp;gt; refused (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:18.778 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/127.0.0.1': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:18.778 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address
&gt; '/fe80:0:0:0:20c:29ff:fea1:6d6b%ens33':
&gt; &amp;gt; Network is unreachable (connect failed)
&gt; &amp;gt; 2021-03-07 10:29:18.778 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/192.168.31.10': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:18.779 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/0:0:0:0:0:0:0:1%lo': Network is
&gt; &amp;gt; unreachable (connect failed)
&gt; &amp;gt; 2021-03-07 10:29:18.779 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/127.0.0.1': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:18.779 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address
&gt; '/fe80:0:0:0:20c:29ff:fea1:6d6b%ens33':
&gt; &amp;gt; Network is unreachable (connect failed)
&gt; &amp;gt; 2021-03-07 10:29:18.779 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/192.168.31.10': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:18.780 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/0:0:0:0:0:0:0:1%lo': Network is
&gt; &amp;gt; unreachable (connect failed)
&gt; &amp;gt; 2021-03-07 10:29:18.780 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/127.0.0.1': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:18.780 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Could not connect. Waiting for 1600 msecs before next attempt
&gt; &amp;gt; 2021-03-07 10:29:20.381 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Trying to connect to localhost/127.0.0.1:6123
&gt; &amp;gt; 2021-03-07 10:29:20.381 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address 'cdh6.com/192.168.31.10': Connection
&gt; &amp;gt; refused (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:20.382 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/127.0.0.1': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:20.383 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address
&gt; '/fe80:0:0:0:20c:29ff:fea1:6d6b%ens33':
&gt; &amp;gt; Network is unreachable (connect failed)
&gt; &amp;gt; 2021-03-07 10:29:20.383 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/192.168.31.10': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:20.383 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/0:0:0:0:0:0:0:1%lo': Network is
&gt; &amp;gt; unreachable (connect failed)
&gt; &amp;gt; 2021-03-07 10:29:20.383 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/127.0.0.1': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:20.384 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address
&gt; '/fe80:0:0:0:20c:29ff:fea1:6d6b%ens33':
&gt; &amp;gt; Network is unreachable (connect failed)
&gt; &amp;gt; 2021-03-07 10:29:20.384 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/192.168.31.10': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:20.384 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/0:0:0:0:0:0:0:1%lo': Network is
&gt; &amp;gt; unreachable (connect failed)
&gt; &amp;gt; 2021-03-07 10:29:20.385 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/127.0.0.1': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:20.385 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Could not connect. Waiting for 1829 msecs before next attempt
&gt; &amp;gt; 2021-03-07 10:29:22.214 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Trying to connect to localhost/127.0.0.1:6123
&gt; &amp;gt; 2021-03-07 10:29:22.215 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address 'cdh6.com/192.168.31.10': Connection
&gt; &amp;gt; refused (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:22.216 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/127.0.0.1': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:22.216 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address
&gt; '/fe80:0:0:0:20c:29ff:fea1:6d6b%ens33':
&gt; &amp;gt; Network is unreachable (connect failed)
&gt; &amp;gt; 2021-03-07 10:29:22.217 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/192.168.31.10': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:22.217 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/0:0:0:0:0:0:0:1%lo': Network is
&gt; &amp;gt; unreachable (connect failed)
&gt; &amp;gt; 2021-03-07 10:29:22.217 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/127.0.0.1': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:22.218 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address
&gt; '/fe80:0:0:0:20c:29ff:fea1:6d6b%ens33':
&gt; &amp;gt; Network is unreachable (connect failed)
&gt; &amp;gt; 2021-03-07 10:29:22.218 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/192.168.31.10': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:22.218 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/0:0:0:0:0:0:0:1%lo': Network is
&gt; &amp;gt; unreachable (connect failed)
&gt; &amp;gt; 2021-03-07 10:29:22.218 [main] INFO&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Failed to connect from address '/127.0.0.1': Connection refused
&gt; &amp;gt; (Connection refused)
&gt; &amp;gt; 2021-03-07 10:29:22.219 [main] WARN&amp;amp;nbsp;
&gt; org.apache.flink.runtime.net.ConnectionUtils&amp;amp;nbsp;
&gt; &amp;gt; - Could not connect to localhost/127.0.0.1:6123. Selecting a local
&gt; &amp;gt; address using heuristics.
&gt; &amp;gt; 2021-03-07 10:29:22.290 [main] WARN&amp;amp;nbsp;
&gt; &amp;gt; org.apache.hadoop.hive.conf.HiveConf&amp;amp;nbsp; - HiveConf of name
&gt; &amp;gt; hive.vectorized.use.checked.expressions does not exist
&gt; &amp;gt; 2021-03-07 10:29:22.290 [main] WARN&amp;amp;nbsp;
&gt; &amp;gt; org.apache.hadoop.hive.conf.HiveConf&amp;amp;nbsp; - HiveConf of name
&gt; &amp;gt; hive.vectorized.use.checked.expressions does not exist
&gt; &amp;gt; 2021-03-07 10:29:22.290 [main] WARN&amp;amp;nbsp;
&gt; &amp;gt; org.apache.hadoop.hive.conf.HiveConf&amp;amp;nbsp; - HiveConf of name
&gt; &amp;gt; hive.strict.checks.no.partition.filter does not exist
&gt; &amp;gt; 2021-03-07 10:29:22.290 [main] WARN&amp;amp;nbsp;
&gt; &amp;gt; org.apache.hadoop.hive.conf.HiveConf&amp;amp;nbsp; - HiveConf of name
&gt; &amp;gt; hive.strict.checks.no.partition.filter does not exist
&gt; &amp;gt; 2021-03-07 10:29:22.290 [main] WARN&amp;amp;nbsp;
&gt; &amp;gt; org.apache.hadoop.hive.conf.HiveConf&amp;amp;nbsp; - HiveConf of name
&gt; &amp;gt; hive.strict.checks.orderby.no.limit does not exist
&gt; &amp;gt; 2021-03-07 10:29:22.290 [main] WARN&amp;amp;nbsp;
&gt; &amp;gt; org.apache.hadoop.hive.conf.HiveConf&amp;amp;nbsp; - HiveConf of name
&gt; &amp;gt; hive.strict.checks.orderby.no.limit does not exist
&gt; &amp;gt; 2021-03-07 10:29:22.291 [main] WARN&amp;amp;nbsp;
&gt; &amp;gt; org.apache.hadoop.hive.conf.HiveConf&amp;amp;nbsp; - HiveConf of name
&gt; &amp;gt; hive.vectorized.input.format.excludes does not exist
&gt; &amp;gt; 2021-03-07 10:29:22.291 [main] WARN&amp;amp;nbsp;
&gt; &amp;gt; org.apache.hadoop.hive.conf.HiveConf&amp;amp;nbsp; - HiveConf of name
&gt; &amp;gt; hive.vectorized.input.format.excludes does not exist
&gt; &amp;gt; 2021-03-07 10:29:22.291 [main] WARN&amp;amp;nbsp;
&gt; &amp;gt; org.apache.hadoop.hive.conf.HiveConf&amp;amp;nbsp; - HiveConf of name
&gt; &amp;gt; hive.strict.checks.bucketing does not exist
&gt; &amp;gt; 2021-03-07 10:29:22.291 [main] WARN&amp;amp;nbsp;
&gt; &amp;gt; org.apache.hadoop.hive.conf.HiveConf&amp;amp;nbsp; - HiveConf of name
&gt; &amp;gt; hive.strict.checks.bucketing does not exist
&gt; &amp;gt; 2021-03-07 10:29:22.291 [main] INFO&amp;amp;nbsp;
&gt; hive.metastore&amp;amp;nbsp; - Trying to
&gt; &amp;gt; connect to metastore with URI thrift://cdh6.com:9083
&gt; &amp;gt; 2021-03-07 10:29:22.292 [main] INFO&amp;amp;nbsp;
&gt; hive.metastore&amp;amp;nbsp; - Opened a
&gt; &amp;gt; connection to metastore, current connections: 2
&gt; &amp;gt; 2021-03-07 10:29:22.301 [main] WARN&amp;amp;nbsp;
&gt; hive.metastore&amp;amp;nbsp; - set_ugi()
&gt; &amp;gt; not successful, Likely cause: new client talking to old server.
&gt; Continuing
&gt; &amp;gt; without it.
&gt; &amp;gt; org.apache.thrift.transport.TTransportException: null
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; org.apache.thrift.transport.TTransport.readAll(TTransport.java:86)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.thrift.protocol.TBinaryProtocol.readStringBody(TBinaryProtocol.java:380)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:230)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:77)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_set_ugi(ThriftHiveMetastore.java:4122)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.set_ugi(ThriftHiveMetastore.java:4108)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.hadoop.hive.metastore.HiveMetaStoreClient.open(HiveMetaStoreClient.java:495)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.hadoop.hive.metastore.HiveMetaStoreClient.<init&amp;amp;gt;(HiveMetaStoreClient.java:286)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.hadoop.hive.metastore.HiveMetaStoreClient.<init&amp;amp;gt;(HiveMetaStoreClient.java:211)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; java.lang.reflect.Constructor.newInstance(Constructor.java:423)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.hadoop.hive.metastore.MetaStoreUtils.newInstance(MetaStoreUtils.java:1652)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.<init&amp;amp;gt;(RetryingMetaStoreClient.java:83)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.getProxy(RetryingMetaStoreClient.java:133)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.getProxy(RetryingMetaStoreClient.java:118)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; java.lang.reflect.Method.invoke(Method.java:498)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.catalog.hive.client.HiveShimV200.getHiveMetastoreClient(HiveShimV200.java:54)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.createMetastoreClient(HiveMetastoreClientWrapper.java:274)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.catalog.hive.client.HiveMetastoreClientWrapper.<init&amp;amp;gt;(HiveMetastoreClientWrapper.java:80)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.catalog.hive.client.HiveMetastoreClientFactory.create(HiveMetastoreClientFactory.java:32)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.connectors.hive.util.HivePartitionUtils.getAllPartitions(HivePartitionUtils.java:114)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.connectors.hive.HiveTableSource.getDataStream(HiveTableSource.java:137)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.connectors.hive.HiveTableSource$1.produceDataStream(HiveTableSource.java:122)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.plan.nodes.common.CommonPhysicalTableSourceScan.createSourceTransformation(CommonPhysicalTableSourceScan.scala:88)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecTableSourceScan.translateToPlanInternal(StreamExecTableSourceScan.scala:91)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecTableSourceScan.translateToPlanInternal(StreamExecTableSourceScan.scala:44)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.plan.nodes.exec.ExecNode$class.translateToPlan(ExecNode.scala:59)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecTableSourceScan.translateToPlan(StreamExecTableSourceScan.scala:44)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecLegacySink.translateToTransformation(StreamExecLegacySink.scala:158)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecLegacySink.translateToPlanInternal(StreamExecLegacySink.scala:82)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecLegacySink.translateToPlanInternal(StreamExecLegacySink.scala:48)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.plan.nodes.exec.ExecNode$class.translateToPlan(ExecNode.scala:59)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecLegacySink.translateToPlan(StreamExecLegacySink.scala:48)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.delegation.StreamPlanner$$anonfun$translateToPlan$1.apply(StreamPlanner.scala:66)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.delegation.StreamPlanner$$anonfun$translateToPlan$1.apply(StreamPlanner.scala:65)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; scala.collection.Iterator$class.foreach(Iterator.scala:891)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; scala.collection.AbstractIterable.foreach(Iterable.scala:54)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; scala.collection.AbstractTraversable.map(Traversable.scala:104)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.delegation.StreamPlanner.translateToPlan(StreamPlanner.scala:65)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:167)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1329)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.api.internal.TableEnvironmentImpl.translateAndClearBuffer(TableEnvironmentImpl.java:1321)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.getPipeline(StreamTableEnvironmentImpl.java:328)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$createPipeline$1(ExecutionContext.java:287)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.client.gateway.local.ExecutionContext.wrapClassLoader(ExecutionContext.java:256)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.client.gateway.local.ExecutionContext.createPipeline(ExecutionContext.java:282)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.client.gateway.local.LocalExecutor.executeQueryInternal(LocalExecutor.java:542)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.client.gateway.local.LocalExecutor.executeQuery(LocalExecutor.java:374)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.client.cli.CliClient.callSelect(CliClient.java:648)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt;
&gt; org.apache.flink.table.client.cli.CliClient.callCommand(CliClient.java:323)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; java.util.Optional.ifPresent(Optional.java:159)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; org.apache.flink.table.client.cli.CliClient.open(CliClient.java:214)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:144)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; org.apache.flink.table.client.SqlClient.start(SqlClient.java:115)
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; at
&gt; &amp;gt; org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
&gt; &amp;gt; 2021-03-07 10:29:22.302 [main] INFO&amp;amp;nbsp;
&gt; hive.metastore&amp;amp;nbsp; - Connected
&gt; &amp;gt; to metastore.
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; [hidden email]
&gt; &amp;gt;
&gt;
&gt;
&gt; --
&gt; Best regards!
&gt; Rui Li



--
Best regards!
Rui Li
Free forum by Nabble Edit this page