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?
