Flink SQL ClassNotFoundException: org.apache.commons.compress.compressors.zstandard.ZstdCompressorIn

Posted @SmartSi

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink SQL ClassNotFoundException: org.apache.commons.compress.compressors.zstandard.ZstdCompressorIn相关的知识,希望对你有一定的参考价值。

1. 现象

在 Flink SQL 中使用 FileSystem Connector 以 CSV 格式读取本地 csv 文件时,抛出如下异常:

Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/commons/compress/compressors/zstandard/ZstdCompressorInputStream
	at org.apache.flink

以上是关于Flink SQL ClassNotFoundException: org.apache.commons.compress.compressors.zstandard.ZstdCompressorIn的主要内容,如果未能解决你的问题,请参考以下文章

Flink学习之flink sql

Flink学习之flink sql

2021年大数据Flink(三十九):​​​​​​​Table与SQL ​​​​​​总结 Flink-SQL常用算子

flink1.12.1扩展flink-sql 支持写入到sqlserver

Flink学习:Flink Table/Sql API

Flink SQL 1.11新功能详解:Hive 数仓实时化 & Flink SQL + CDC 实践