tongchenkeji
发表于：0次点击

这个是flink-cdc 2.4引入的。我用的就是这个版本，咋还报这个错误?[阿里云]

这个是flink-cdc 2.4引入的。我用的就是这个版本，咋还报这个错误?

且在这个没问题
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

连远端就有问题
StreamExecutionEnvironment env = StreamExecutionEnvironment.createRemoteEnvironment(“192.168.0.235”, 8081);

「点点赞赏，手留余香」

    还没有人赞赏，快来当第一个赞赏的人吧！
阿里云# 实时计算 Flink版3179
=====这是一个广告位，招租中，联系qq 78315851====
阿里云
Flink CDC 过期时间是 7天，但是还是报了拉取不到 binlog?[阿里云]
阿里云
Flink CDC这个错误怎么解决?[阿里云]
2 条回复 A 作者 M 管理员

  1. 这个错误可能是由于Flink CDC 2.4版本与您的MySQL连接器版本不兼容导致的。您可以尝试以下方法解决这个问题：

    1. 确保您使用的MySQL连接器版本与Flink CDC 2.4兼容。您可以查看Flink CDC官方文档，了解支持的MySQL连接器版本。

    2. 如果问题仍然存在，您可以尝试降级Flink CDC的版本，以找到一个与您的MySQL连接器版本兼容的版本。

    3. 检查您的项目依赖，确保所有必要的库都已正确添加。如果您使用的是Maven或Gradle，请确保在pom.xml或build.gradle文件中添加了正确的依赖项。

    已喜欢 已反对

  2. 根据你提供的代码，这个错误是由于找不到名为”com.ververica.cdc.connectors.mysql.source.MySqlSource”的类。这个错误可能是由于以下原因导致的：

    1. 你可能没有正确地在你的项目中添加了Flink CDC MySQL源的依赖。请确保你已经正确地添加了依赖。
    2. 你可能没有正确地配置了Flink CDC MySQL源的类路径。请检查你的类路径配置，确保它包含了Flink CDC MySQL源的类。
    3. 你可能没有正确地设置了Flink CDC MySQL源的类路径。请检查你的Flink配置，确保它包含了Flink CDC MySQL源的类路径。
    已喜欢 已反对

  3. 是你远程端没这个包，本地提交代码到远程机器上运行，当然会报找不到类,要重启哈，此回答整理自钉群“Flink CDC 社区”

    已喜欢 已反对