You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "龚旭伦 (Jira)" <ji...@apache.org> on 2020/08/12 14:41:00 UTC
[jira] [Created] (FLINK-18903) Flink集成Hive内置时间函数使用报错
龚旭伦 created FLINK-18903:
---------------------------
Summary: Flink集成Hive内置时间函数使用报错
Key: FLINK-18903
URL: https://issues.apache.org/jira/browse/FLINK-18903
Project: Flink
Issue Type: Bug
Components: Connectors / Hive
Affects Versions: 1.11.1
Environment: HDP版本：2.4.2.0-258
Hive版本：1.2.1
Flink版本：1.11.1
Flink-sql-client配置见附件：sql-client-defaults.yaml
Flink jobmanager 启动模式：yarn-session模式
Flink lib目录已经按官方文档添加如下jar包：
{code:java}
-rw-r--r-- 1 root root 130802 Aug 10 20:09 aircompressor-0.8.jar
-rw-r--r-- 1 root root 90782 Jul 15 17:24 flink-csv-1.11.1.jar
-rw-r--r-- 1 root root 108350618 Jul 15 17:30 flink-dist_2.11-1.11.1.jar
-rw-r--r-- 1 root root 80837 Aug 10 19:41 flink-hadoop-compatibility_2.11-1.11.1.jar
-rw-r--r-- 1 root root 94865 Jul 15 17:24 flink-json-1.11.1.jar
-rw-r--r-- 1 root root 36309656 Aug 11 20:11 flink-shaded-hadoop-2-uber-2.6.5-10.0.jar
-rw-r--r-- 1 root root 7712156 Jun 18 10:42 flink-shaded-zookeeper-3.4.14.jar
-rw-r--r-- 1 root root 31714606 Aug 10 15:13 flink-sql-connector-hive-1.2.2_2.11-1.11.0.jar
-rw-r--r-- 1 root root 3541642 Aug 10 15:12 flink-sql-connector-kafka_2.11-1.11.0.jar
-rw-r--r-- 1 root root 2100826 Aug 10 17:13 flink-sql-orc_2.11-1.11.0.jar
-rw-r--r-- 1 root root 33327194 Jul 15 17:28 flink-table_2.11-1.11.1.jar
-rw-r--r-- 1 root root 37331759 Jul 15 17:28 flink-table-blink_2.11-1.11.1.jar
-rw-r--r-- 1 root root 20599029 Aug 11 22:17 hive-exec-1.2.1.jar
lrwxrwxrwx 1 root root 69 Aug 10 17:15 hive-metastore-1.2.1000.2.4.2.0-258.jar -> /usr/hdp/2.4.2.0-258/hive/lib/hive-metastore-1.2.1000.2.4.2.0-258.jar
-rw-r--r-- 1 root root 918379 Aug 11 22:32 hive-serde-1.2.1000.2.4.2.0-258.jar
lrwxrwxrwx 1 root root 51 Aug 10 00:19 jersey-core-1.9.jar -> /usr/hdp/2.4.2.0-258/hadoop/lib/jersey-core-1.9.jar
lrwxrwxrwx 1 root root 48 Aug 10 17:17 libfb303-0.9.2.jar -> /usr/hdp/2.4.2.0-258/hive/lib/libfb303-0.9.2.jar
-rw-r--r-- 1 root root 67114 Apr 20 20:47 log4j-1.2-api-2.12.1.jar
-rw-r--r-- 1 root root 276771 Apr 20 20:47 log4j-api-2.12.1.jar
-rw-r--r-- 1 root root 1674433 Apr 20 20:47 log4j-core-2.12.1.jar
-rw-r--r-- 1 root root 23518 Apr 20 20:47 log4j-slf4j-impl-2.12.1.jar
-rw-r--r-- 1 root root 733071 Aug 10 20:09 orc-core-1.4.3.jar
{code}
Reporter: 龚旭伦
Attachments: flink-sql-client.log, image-2020-08-12-21-59-58-394.png, image-2020-08-12-22-17-37-002.png, sql-client-defaults.yaml
【问题描述】
我在HDP集群上部署了一套Flink on YARN，并且根据官方文档在Flink SQL上集成Hive，集成后发现Hive内置的部分时间函数使用报错（其他函数使用正常），详细如下：
报错函数：current_date,current_timestamp
!image-2020-08-12-21-59-58-394.png|width=585,height=223!
详细报错堆栈见附件：flink-sql-client.log
【问题分析】
1.对current_date函数报错堆栈log的分析，发现产生NullPointerException的代码行为GenericUDFCurrentDate.java:52
2.查阅Hive源码：
!image-2020-08-12-22-17-37-002.png|width=632,height=262!
怀疑是SessionState对象在Flink-sql-client中没有初始化而产生的NullPointerException。由于本人知识水平有限，没办法再深入分析其报错原因，麻烦社区帮忙确认并给出修复建议哈。
--
This message was sent by Atlassian Jira
(v8.3.4#803005)