Flink CDC部署war包之后启动报错这个是什么问题?

展开

收起

真的很搞笑 2023-11-22 09:34:01 109 0

3 条回答

写回答

取消提交回答

小周sir

面对过去，不要迷离；面对未来，不必彷徨；活在今天，你只要把自己完全展示给别人看。
错误提示 "No ExecutorFactory found to execute the application." 通常表示 Flink CDC 的执行环境无法找到合适的执行工厂来执行应用。
这可能是因为您的 Flink CDC 版本与正在使用的 Flink 版本不兼容，或者是因为缺少必要的 JAR 包或依赖项。
建议您检查以下几个方面：
1. 确保您的 Flink CDC 版本与 Flink 版本相匹配。可以在 Flink 官方文档中查找相应的版本信息。
2. 确保您的项目中包含了所有的必需 JAR 包和依赖项。您可以查看 Flink CDC 文档中的相关章节来了解所需的依赖项。
3. 如果您使用的是 Maven 工具，可以尝试重新构建您的项目，以确保所有必需的 JAR 包和依赖项都被包含在内。
2023-11-29 13:32:23

赞同展开评论打赏
sunrr
这个错误提示 "No ExecutorFactory found to execute the application." 通常出现在 Flink 的应用启动过程中。这个错误表示 Flink 无法找到合适的执行器工厂来执行你的应用程序。

这可能是因为你的 Flink 配置文件中没有正确配置执行器工厂。你需要在 Flink 的配置文件中指定执行器工厂的类名。

你可以尝试以下步骤来解决这个问题：
1. 检查你的 Flink 配置文件（通常是 flink-conf.yaml 或 flink-conf.xml），确保已经正确配置了执行器工厂的类名。
2. 如果你使用的是 Flink 的命令行工具来启动应用，你需要在命令行中指定执行器工厂的类名。例如，如果你的执行器工厂的类名是 org.apache.flink.runtime.entrypoint.DefaultExecutorFactory，你可以使用以下的命令来启动应用：
  
  flink run -c org.apache.flink.runtime.entrypoint.DefaultExecutorFactory <your_application_JAR>
2023-11-29 12:01:15

赞同展开评论打赏
芯在这

目前，ddl change 会导致scheme不对的，可以全量补数据绕过，或者最新启动（或者时间戳跳过），然后batch run （补一下出错这段时间的数据）。，此回答整理自钉群“Flink CDC 社区”

2023-11-22 12:13:27

赞同展开评论打赏