开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink On Docker 启动 jm 时报这个错误请问有知道这个错误的原因吗?

请问有大佬知道这个错误的原因吗?Flink On Docker 启动 jm 时报这个错误?403dbf3e66152fc4c2b9b1fe659af598.png

展开
收起
真的很搞笑 2024-05-14 17:21:29 71 0
5 条回答
写回答
取消 提交回答
  • 关于您提到的 Flink 在 Docker 上启动 JobManager (JM) 时遇到的错误,可能的原因和解决方法如下:

    1. 使用正确的执行环境:错误信息可能表明您尝试在 Apache Flink 中提交一个程序,但是使用了 LocalStreamEnvironment。LocalStreamEnvironment 是用于本地执行的环境,而当您通过客户端提交程序或在 TestEnvironment 上运行时,应该使用其他类型的环境(如 StreamExecutionEnvironment)。解决这个问题的方法是确保您的代码中没有使用 LocalStreamEnvironment,并且正确地配置了 StreamExecutionEnvironment 来提交应用程序。
    2. 检查 Docker 容器配置:确保 Docker 容器的资源(如 CPU、内存)分配足够,以支持 Flink JM 和 TM(TaskManager)的运行。同时,检查 Docker 容器的网络配置,确保 Flink 集群的各个组件之间可以相互通信。
    3. 检查 Flink 配置文件:确保 Flink 的配置文件(如 flink-conf.yaml)所有必要的配置项都已正确设置,特别是与集群管理、网络、存储等相关的配置项。
    4. 尝试简化问题:如果可能,尝试使用最简单的 Flink 作业来启动,看看问题是否仍然存在或者尝试拉取一次新的 Flink 镜像。
    5. 检查日志:详细查看 Flink 的日志文件,通常可以在 Flink Web UI 的日志界面上找到 TaskManager 和 JobManager 的日志文件,以获取更详细的错误信息。
      如果您能够提供更具体的错误信息或日志内容,我可以提供更具体的建议。
    2024-07-27 20:49:51
    赞同 展开评论 打赏
  • 这个错误信息表明您尝试在 Apache Flink 中提交一个程序,但是使用了 LocalStreamEnvironment。LocalStreamEnvironment 是用于本地执行的环境,而当您通过客户端提交程序或在 TestEnvironment 上运行时,应该使用其他类型的环境(如 StreamExecutionEnvironment)。

    解决这个问题的方法是确保您的代码中没有使用 LocalStreamEnvironment,并且正确地配置了 StreamExecutionEnvironment 来提交应用程序。以下是一个简单的示例来说明如何更改:image.png
    将上述代码替换为正确的环境设置后,您可以再次尝试提交程序。

    2024-07-26 15:38:49
    赞同 展开评论 打赏
  • 阿里云大降价~

    看日志貌似看不出,建议简化问题,尝试使用最简单的 Flink 作业来启动,看看问题是否仍然存在或者再拉一次FLINK 镜像试试

    2024-07-25 11:17:38
    赞同 展开评论 打赏
  • 报错是因为用的是“createLocalEnvironment()”

    解决办法:使用ExecutionEnvironment.getExecutionEnvironment()

    //StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment();
    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
    

    ——参考链接

    2024-07-24 11:54:32
    赞同 1 展开评论 打赏
  • 当你在 Docker 容器中启动 Flink 的 JobManager(JM)时遇到关于“submitting a program through a client, or running in a TestEnvironment context”的错误,这通常并不是一个直接指向 JM 启动问题的错误消息。这个错误描述更可能是与 Flink 程序的提交方式或运行上下文有关,而不是直接针对 JM 启动过程的。

    然而,这里有几个可能的原因和解决方案,你可以逐一排查:

    错误的提交方式:
    确保你不是在尝试在 Docker 容器内通过 Flink 客户端(CLI)直接提交作业,而实际上应该通过外部客户端或应用程序来提交。
    如果你确实需要在 Docker 容器内提交作业,确保你的 Flink 配置文件(如 flink-conf.yaml)和提交命令正确设置了所有必要的参数,特别是与集群配置和作业提交相关的部分。
    TestEnvironment 使用:
    错误消息中提到“TestEnvironment context”,这通常是在开发环境中使用 Flink 的 StreamExecutionEnvironment.getExecutionEnvironment() 时,如果 Flink 检测到它是在测试环境中运行(例如,IDE或JUnit测试),则会自动选择 TestEnvironment。但在生产环境中,你应该确保 Flink 不是在测试模式下运行。
    检查你的 Flink 程序是否在不应该的情况下使用了 TestEnvironment。如果是的话,请改为使用 StreamExecutionEnvironment.createLocalEnvironment() 或 StreamExecutionEnvironment.getExecutionEnvironment()(根据具体情况)。
    Docker 容器配置:
    确保 Docker 容器的资源(如 CPU、内存)分配足够,以支持 Flink JM 和 TM(TaskManager)的运行。
    检查 Docker 容器的网络配置,确保 Flink 集群的各个组件之间可以相互通信。
    Flink 配置文件:
    检查 Flink 的配置文件(如 flink-conf.yaml),确保所有必要的配置项都已正确设置,特别是与集群管理、网络、存储等相关的配置项。

    2024-07-24 10:27:48
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载