Apache Flink China读hive报这个,该怎么解决?[阿里云实时计算 Flink版]

Caused by: java.lang.NullPointerException at org.apache.hadoop.hive.ql.io.orc.RecordReaderImpl$StringDictionaryTreeReader.startStripe(RecordReaderImpl.java:1560) at org.apache.hadoop.hive.ql.io.orc.RecordReaderImpl$StringTreeReader.startStripe(RecordReaderImpl.java:1332) at org.apache.hadoop.hive.ql.io.orc.RecordReaderImpl$StructTreeReader.startStripe(RecordReaderImpl.java:1912) at org.apache.hadoop.hive.ql.io.orc.RecordReaderImpl.readStripe(RecordReaderImpl.java:2662) at org.apache.hadoop.hive.ql.io.orc.RecordReaderImpl.advanceStripe(RecordReaderImpl.java:3081) at org.apache.hadoop.hive.ql.io.orc.RecordReaderImpl.advanceToNextRow(RecordReaderImpl.java:3123) at org.apache.hadoop.hive.ql.io.orc.RecordReaderImpl.(RecordReaderImpl.java:289) at org.apache.hadoop.hive.ql.io.orc.ReaderImpl.rowsOptions(ReaderImpl.java:534) at org.apache.hadoop.hive.ql.io.orc.OrcInputFormat.createReaderFromFile(OrcInputFormat.java:225) at org.apache.hadoop.hive.ql.io.orc.OrcInputFormat$OrcRecordReader.(OrcInputFormat.java:157) flink 读hive报这个,该怎么解决?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. 您在使用阿里云实时计算 Flink版中读取 Hive 数据时,出现 NullPointerException 错误。根据错误信息,问题可能是由于在读取 ORC 格式的 Hive 表时,无法正确地解析某些数据导致的。

    具体来说,异常信息指出在 RecordReaderImpl 的方法中,执行 StringDictionaryTreeReader 或者 StringTreeReader 或者 StructTreeReader 时,发生了 NullPointerException 错误。由此推测,可能是某些数据的值为空或为 null,导致不能正确解析数据所引起的。

    为了解决这个问题,建议您检查数据源中的数据,特别是对可能为空或 null 的字段进行检查。如果是针对某个特定表或字段,请尝试在 SQL 或者代码中加入判空逻辑,避免空值引起的异常。

  2. 只能大致给个方向,怀疑是hive的orc文件异常导致的报空指针异常