启动flink连接不到flink容器的被拒绝,有知道是啥情况嘛?[阿里云实时计算 Flink版]

启动flink连接不到flink容器的被拒绝,有大佬知道是啥情况嘛?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. 请检查以下几点以解决问题:

    1. 确保网络畅通。请检查主机和 Docker 容器之间的网络连接,如iptables、firewall 等;
    2. 确保 Docker 容器和主机的端口映射设置正确;
    3. 检查 Flink 配置文件是否正确;
    4. 请检查环境变量 FLINK_RPC_PORT 等是否正确设置;
    5. 检查 Flink REST API 的调用是否正确。
  2. 这个问题可能是由于类加载器的问题导致的。在Java中,类加载器负责从文件系统、网络或其他来源加载字节码到JVM中。当两个不同的类加载器尝试加载相同的类时,可能会出现问题。

    在这种情况下,com.ververica.cdc.debezium.internal.DebeziumChangeConsumerio.debezium.embedded.EmbeddedEnginechangeEvent 可能由不同的类加载器加载。当你尝试从 DebeziumChangeConsumer 访问 EmbeddedEnginechangeEvent 时,可能会遇到 IllegalAccessError

    要解决这个问题,你可以尝试以下方法:

    1. 确保你的项目中没有重复的依赖项,特别是与Flink相关的依赖项。检查你的 pom.xmlbuild.gradle 文件,确保没有重复的依赖项。

    2. 如果你使用的是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>
    1. 如果问题仍然存在,尝试将项目打包成一个可执行的JAR文件,并确保所有依赖项都包含在其中。然后,从命令行运行这个JAR文件,看看是否可以正常启动。