[
https://issues.apache.org/jira/browse/FLINK-19025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184946#comment-17184946
]
McClone commented on FLINK-19025:
---------------------------------
Exception in thread "main" java.lang.NoClassDefFoundError:
org/apache/orc/PhysicalWriterException in thread "main"
java.lang.NoClassDefFoundError: org/apache/orc/PhysicalWriter at
org.apache.flink.table.catalog.hive.client.HiveShimV200.createOrcBulkWriterFactory(HiveShimV200.java:60)
at
org.apache.flink.connectors.hive.HiveTableSink.createBulkWriterFactory(HiveTableSink.java:251)
at
org.apache.flink.connectors.hive.HiveTableSink.consumeDataStream(HiveTableSink.java:192)
at
org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecLegacySink.translateToPlanInternal(StreamExecLegacySink.scala:114)
at
org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecLegacySink.translateToPlanInternal(StreamExecLegacySink.scala:48)
at
org.apache.flink.table.planner.plan.nodes.exec.ExecNode$class.translateToPlan(ExecNode.scala:58)
at
org.apache.flink.table.planner.plan.nodes.physical.stream.StreamExecLegacySink.translateToPlan(StreamExecLegacySink.scala:48)
at
org.apache.flink.table.planner.delegation.StreamPlanner$$anonfun$translateToPlan$1.apply(StreamPlanner.scala:67)
at
org.apache.flink.table.planner.delegation.StreamPlanner$$anonfun$translateToPlan$1.apply(StreamPlanner.scala:66)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
at scala.collection.Iterator$class.foreach(Iterator.scala:891) at
scala.collection.AbstractIterator.foreach(Iterator.scala:1334) at
scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at
scala.collection.AbstractIterable.foreach(Iterable.scala:54) at
scala.collection.TraversableLike$class.map(TraversableLike.scala:234) at
scala.collection.AbstractTraversable.map(Traversable.scala:104) at
org.apache.flink.table.planner.delegation.StreamPlanner.translateToPlan(StreamPlanner.scala:66)
at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:166)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1248)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:694)
at
org.apache.flink.table.api.internal.StatementSetImpl.execute(StatementSetImpl.java:97)
at com.galaxy.sunny.flink.StartTableJob.main(StartTableJob.java:45)Caused by:
java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter 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) ... 23 more
> table sql write orc file but hive2.1.1 can not read
> ---------------------------------------------------
>
> Key: FLINK-19025
> URL: https://issues.apache.org/jira/browse/FLINK-19025
> Project: Flink
> Issue Type: Bug
> Components: Connectors / ORC
> Affects Versions: 1.11.0
> Reporter: McClone
> Priority: Major
>
> table sql write orc file but hive2.1.1 create external table can not read
> data.Because flink use orc-core-1.5.6.jar but hive 2.1.1 use his own orcfile
> jar.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
