You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Leonard Xu (Jira)" <ji...@apache.org> on 2021/01/28 08:26:00 UTC
[jira] [Closed] (FLINK-18903) Flink集成Hive内置时间函数使用报错
[ https://issues.apache.org/jira/browse/FLINK-18903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Leonard Xu closed FLINK-18903.
------------------------------
Resolution: Invalid
Thanks for the report, but please use English in JIRA
> 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: 龚旭伦
> Priority: Major
> Labels: flink, hive, sql, 内置函数
> 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)