apache-flink - 梁流水线作业未提交给 flink jobmanager
问题描述
我有 5 个由 java Beam 实现的不同管道，并作为独立集群在 flink 上运行。他们都是流媒体工作。这些管道正在将信息写入大查询 (gcp)。我正在运行 1 个作业管理器、5 个任务管理器、每个 1 个插槽。
问题是 5 个作业中只有 4 个通过其 rest 服务提交给 jobmanager。第五个没有提交，没有错误。
这只发生在与 gcp 相关的管道上。有什么想法吗？
谢谢小号
解决方案
推荐阅读
- java - 如何添加多个前缀 - JDA
- pytorch - torchvision MNIST HTTPError：HTTP 错误 403：禁止
- arduino - 如何识别和区分 Arduino 中的单击、双击和三次单击？
- sql - 如何使用 params[:sort] 值按联接表列对 ActiveRecord 集合进行排序
- vue.js - Vue 模板与 Vue jsx
- python - 如何在运行配置中传递多个 pytest 命令行选项
- javascript - AJAX 返回整个 html - 我怎样才能只返回一个值？
- javascript - 如何修复随机填充的 HTML 表格？
- java - Android - 根据格林威治标准时间设置时间数据
- .net - MimeKit.MimeMessage 的哪个客户端？