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的主要内容,如果未能解决你的问题,请参考以下文章
2021年大数据Flink(三十九):Table与SQL 总结 Flink-SQL常用算子