Re: Re: [Blink]sql client kafka sink 失败

能不能看一下运行sql-client.sh的运行参数。具体做法是: 运行sql-client.sh ps | grep sql-client 查看一下其中是不是有这个 flink-connector-kafka-0.11 的 jar. Jiangjie (Becket) Qin On Fri, Feb 22, 2019 at 6:54 PM 张洪涛 wrote: > > > 是包含这个类的 > > > jar -tf flink-connector-kafka-0.11_2.11-*.jar | grep Crc32C > >

Re:Re: [Blink]sql client kafka sink 失败

是包含这个类的 jar -tf flink-connector-kafka-0.11_2.11-*.jar | grep Crc32C org/apache/flink/kafka011/shaded/org/apache/kafka/common/utils/Crc32C$1.class org/apache/flink/kafka011/shaded/org/apache/kafka/common/utils/Crc32C$ChecksumFactory.class