hi
从报错上看是缺少了 Flink-sql-kafka 那个包,把这个包添加到 Flink/lib 下面再跑一下
-
Best Wishes
JasonLee
--
Sent from: http://apache-flink.147419.n8.nabble.com/
您好，
flink-sql-connector-kafka_2.11-1.11.3.jar
这个包已经在flink的lib目录下了。
maker_d...@foxmail.com
发件人： JasonLee
发送时间： 2021-04-25 17:56
收件人： user-zh
主题： Re: 提交FlinkSQLKafka表报异常cannt load user class
hi
从报错上看是缺少了 Flink-sql-kafka 那个包,把这个包添加到 Flink/lib 下面再跑一下
-
Best Wishes
JasonLee
--
Sent
hi
从报错上看是缺少了 Flink-sql-kafka 那个包,把这个包添加到 Flink/lib 下面再跑一下
-
Best Wishes
JasonLee
--
Sent from: http://apache-flink.147419.n8.nabble.com/
社区各位大佬大家好，
我想通过flinkcdc读取mysql表，然后发送到kafka表。
在我使用sql-client客户端向kafka表插入数据时，报如下错误：
2021-04-25 17:21:03
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
at
