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? 

[Rui Li]

Hi WSJian,

The pictures can't be displayed. Please just copy/paste the stack trace.

And btw, the user mailing list ([hidden email]) is usually more
appropriate for such issues.

On Wed, Apr 28, 2021 at 11:36 AM WSJian <[hidden email]> wrote:

> 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?
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>

--
Best regards!
Rui Li