flink1.12.2 CLI连接hive出现异常,怎么解决?
使用flink1.12.2 CLI连接hive时,可以查看到catalog,也能看到指定的catalog下的tables,但是执行select 语句时就出现异常。 [ERROR] Could not execute SQL statement. Reason: org.apache.hadoop.ipc.RemoteException: Application with id 'applicat....
flink1.12.2 CLI连接hive出现异常怎么办?
使用flink1.12.2 CLI连接hive时,可以查看到catalog,也能看到指定的catalog下的tables,但是执行select 语句时就出现异常。* [ERROR] Could not execute SQL statement. Reason: org.apache.hadoop.ipc.RemoteException: Application with id 'applica....
Flink 1.10连接hive时kerberos认证异常问题
我使用Flink 1.10集成hive,在连接metastore的时候由于hive对应CDH集群开启了kerberos认证,抛出了如下异常:请问大家这个该怎么配置或者解决哈? 999 [main] INFO hive.metastore - Trying to connect to metastore with URI thrift://namenode01.htsc.com:9083 117.....
Flink 连接Hive hiveConf路径配置怎么处理?
flink在连接hive时,需配置hiveConf所在路径 我已经下载了集群中hive-site.xml文件,不知道应该放在哪个目录 Job部署模式是 on Yarn ,请问代码中hiveConf应该放在哪个目录下,应该不是我启动job所在的机器吧?因为job提交后运行在hadoop集群,是无法找到相关目录的。*来自志愿者整理的flink邮件归档
jdbc连接hive查询报错:local host is: (unknown);?报错
hive sql: select row_number() over (order by trademark) id,* from iot.dr_ps_20171228 limit 1 报错信息: java.net.UnknownHostException: Invalid host name: local host is: (unknown); destination host is: "...
spring环境下使用JDBC连接hive,查询表数据量,会查询超时?报错
在spring的环境下,使用hive-jdbc-0.13.1.jar的hive连接,查询某一张表的数量(count做的),会报java.sql.SQLException: org.apache.thrift.transport.TTransportException: java.net.SocketTimeoutException: Read timed out。但是如果脱离spring的环境,....
有没有flink 1.9 连接 hive的例子啊?官网文档试了,没成功
有没有flink 1.9 连接 hive的例子啊?官网文档试了,没成功 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。