Flink清洗过程

来源：13-7 使用Flink进行数据清洗

簖

2021-12-09

Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=2, backoffTimeMS=5000)

Caused by: java.lang.NoClassDefFoundError: org/apache/flink/util/concurrent/ExecutorThreadFactory

JdbcExecutionOptions.builder().withBatchSize(50).withBatchIntervalMs(4000).build(),当我删除这个语句数据量插入不了但小数据流能插入并不报错

写回答

1回答

Michael_PK

2021-12-12

这个错，说异常信息来看，像是版本的兼容问题，在运行时，你pom中的依赖的jar中并没有找到org/apache/flink/util/concurrent/ExecutorThreadFactory这个类。

你的版本和课程使用的版本一样吗

Flink+ClickHouse 玩转企业级实时大数据开发

已经在做大数据，Flink助力轻松提薪；尚未入行，让你弯道超车

1000 学习 · 225 问题

查看课程

相似问题

flink jar 部署

回答 1

flink jdbc oracle

回答 1

flink的重启策略和yarn的恢复机制

回答 1

如何用代码提交打包好的job到flink集群？

回答 1

Flink SQL提交

回答 1

打开慕课网App查看更多内容