You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/08/12 07:31:00 UTC
[jira] [Assigned] (FLINK-18682) Vector orc reader cannot read Hive
2.0.0 table
[ https://issues.apache.org/jira/browse/FLINK-18682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jingsong Lee reassigned FLINK-18682:
------------------------------------
Assignee: Rui Li
> Vector orc reader cannot read Hive 2.0.0 table
> ----------------------------------------------
>
> Key: FLINK-18682
> URL: https://issues.apache.org/jira/browse/FLINK-18682
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Hive, Formats (JSON, Avro, Parquet, ORC, SequenceFile)
> Affects Versions: 1.11.1
> Reporter: Rui Li
> Assignee: Rui Li
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 1.11.2
>
>
> Trying to read a Hive 2.0.0 ORC table fails with:
> {noformat}
> Caused by: java.lang.NoClassDefFoundError: org/apache/hadoop/hive/ql/exec/vector/TimestampColumnVector
> at org.apache.flink.orc.OrcSplitReaderUtil.lambda$genPartColumnarRowReader$0(OrcSplitReaderUtil.java:83)
> at org.apache.flink.orc.OrcColumnarRowSplitReader.<init>(OrcColumnarRowSplitReader.java:65)
> at org.apache.flink.orc.OrcSplitReaderUtil.genPartColumnarRowReader(OrcSplitReaderUtil.java:91)
> at org.apache.flink.connectors.hive.read.HiveVectorizedOrcSplitReader.<init>(HiveVectorizedOrcSplitReader.java:78)
> at org.apache.flink.connectors.hive.read.HiveTableInputFormat.open(HiveTableInputFormat.java:137)
> at org.apache.flink.connectors.hive.read.HiveTableInputFormat.open(HiveTableInputFormat.java:66)
> at org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction.run(InputFormatSourceFunction.java:85)
> at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)
> at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
> at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:201)
> Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.hive.ql.exec.vector.TimestampColumnVector
> at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
> ... 10 more
> {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)