tongchenkeji 发表于:2023-10-30 18:48:060次点击 已关注取消关注 关注 私信 启动flink连接不到flink容器的被拒绝,有知道是啥情况嘛?[阿里云实时计算 Flink版] 暂停朗读为您朗读 启动flink连接不到flink容器的被拒绝,有大佬知道是啥情况嘛? 「点点赞赏,手留余香」 赞赏 还没有人赞赏,快来当第一个赞赏的人吧! 海报 实时计算Flink版# 实时计算 Flink版3179# 容器895# 流计算2236
小周sirAM 2023-11-27 18:37:57 1 请检查以下几点以解决问题: 确保网络畅通。请检查主机和 Docker 容器之间的网络连接,如iptables、firewall 等; 确保 Docker 容器和主机的端口映射设置正确; 检查 Flink 配置文件是否正确; 请检查环境变量 FLINK_RPC_PORT 等是否正确设置; 检查 Flink REST API 的调用是否正确。
sun20AM 2023-11-27 18:37:57 2 这个问题可能是由于类加载器的问题导致的。在Java中,类加载器负责从文件系统、网络或其他来源加载字节码到JVM中。当两个不同的类加载器尝试加载相同的类时,可能会出现问题。 在这种情况下,com.ververica.cdc.debezium.internal.DebeziumChangeConsumer 和 io.debezium.embedded.EmbeddedEnginechangeEvent 可能由不同的类加载器加载。当你尝试从 DebeziumChangeConsumer 访问 EmbeddedEnginechangeEvent 时,可能会遇到 IllegalAccessError。 要解决这个问题,你可以尝试以下方法: 确保你的项目中没有重复的依赖项,特别是与Flink相关的依赖项。检查你的 pom.xml 或 build.gradle 文件,确保没有重复的依赖项。 如果你使用的是Maven,可以尝试在 pom.xml 文件中添加以下配置,以确保使用正确的类加载器: <build> <plugins> <plugin> <groupId>org.apache.maven.pluginsgroupId> <artifactId>maven-compiler-pluginartifactId> <version>3.8.0version> <configuration> <source>1.8source> <target>1.8target> <annotationProcessorPaths> <path> <groupId>org.projectlombokgroupId> <artifactId>lombokartifactId> <version>1.18.20version> path> annotationProcessorPaths> configuration> plugin> plugins>build> 如果问题仍然存在,尝试将项目打包成一个可执行的JAR文件,并确保所有依赖项都包含在其中。然后,从命令行运行这个JAR文件,看看是否可以正常启动。
请检查以下几点以解决问题:
这个问题可能是由于类加载器的问题导致的。在Java中,类加载器负责从文件系统、网络或其他来源加载字节码到JVM中。当两个不同的类加载器尝试加载相同的类时,可能会出现问题。
在这种情况下,
com.ververica.cdc.debezium.internal.DebeziumChangeConsumer
和io.debezium.embedded.EmbeddedEnginechangeEvent
可能由不同的类加载器加载。当你尝试从DebeziumChangeConsumer
访问EmbeddedEnginechangeEvent
时,可能会遇到IllegalAccessError
。要解决这个问题,你可以尝试以下方法:
确保你的项目中没有重复的依赖项,特别是与Flink相关的依赖项。检查你的
pom.xml
或build.gradle
文件,确保没有重复的依赖项。如果你使用的是Maven,可以尝试在
pom.xml
文件中添加以下配置,以确保使用正确的类加载器: