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

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

展开
收起
真的很搞笑 2023-10-30 18:48:06 255 分享 版权
2 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    请检查以下几点以解决问题:

    1. 确保网络畅通。请检查主机和 Docker 容器之间的网络连接,如iptables、firewall 等;
    2. 确保 Docker 容器和主机的端口映射设置正确;
    3. 检查 Flink 配置文件是否正确;
    4. 请检查环境变量 FLINK_RPC_PORT 等是否正确设置;
    5. 检查 Flink REST API 的调用是否正确。
    2023-10-31 15:06:03
    赞同 展开评论
  • 这个问题可能是由于类加载器的问题导致的。在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.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.8.0</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                    <annotationProcessorPaths>
                        <path>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                            <version>1.18.20</version>
                        </path>
                    </annotationProcessorPaths>
                </configuration>
            </plugin>
        </plugins>
    </build>
    
    1. 如果问题仍然存在,尝试将项目打包成一个可执行的JAR文件,并确保所有依赖项都包含在其中。然后,从命令行运行这个JAR文件,看看是否可以正常启动。
    2023-10-31 14:59:05
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理