Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-18903

Flink集成Hive内置时间函数使用报错

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Invalid
    • 1.11.1
    • None
    • Connectors / Hive

    Description

      【问题描述】

      我在HDP集群上部署了一套Flink on YARN,并且根据官方文档在Flink SQL上集成Hive,集成后发现Hive内置的部分时间函数使用报错(其他函数使用正常),详细如下:

      报错函数:current_date,current_timestamp

      详细报错堆栈见附件:flink-sql-client.log

      【问题分析】

      1.对current_date函数报错堆栈log的分析,发现产生NullPointerException的代码行为GenericUDFCurrentDate.java:52

      2.查阅Hive源码:

      怀疑是SessionState对象在Flink-sql-client中没有初始化而产生的NullPointerException。由于本人知识水平有限,没办法再深入分析其报错原因,麻烦社区帮忙确认并给出修复建议哈。

       

       

      Attachments

        1. sql-client-defaults.yaml
          6 kB
          龚旭伦
        2. image-2020-08-12-22-17-37-002.png
          30 kB
          龚旭伦
        3. flink-sql-client.log
          46 kB
          龚旭伦
        4. image-2020-08-12-21-59-58-394.png
          34 kB
          龚旭伦

        Issue Links

          Activity

            People

              Unassigned Unassigned
              xulun 龚旭伦
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: