flink1.12.1 read hive orc table exception. could not initialize class org.apache.orc.impl.ZlibCodec

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink1.12.1 read hive orc table exception. could not initialize class org.apache.orc.impl.ZlibCodec

WSJian
flink lib jar:

flink taskmanager log:

hive orc table create ddl:
create table xxx ... stored as orc

flink java class, Join the hive Orc table and Kafka stream data:
bsTableEnv.executeSql("my sql is join");
flink pom.xml in the attachment.

I convert the file type to textfile type to run. But orc throw this exception.
Or I missing any dependency on the flink lib? Or class file conflict? 















pom.xml (5K) Download Attachment