apache-flink - Flink 作业生产就绪 - 验证分配给所有操作员的 UUID

flink 生产就绪 ( https://ci.apache.org/projects/flink/flink-docs-stable/ops/production_ready.html ) 建议将 UUID 分配给所有操作员。我正在寻找一种方法来验证给定作业图中的所有操作员是否已分配 UUID - 理想情况下用作我们 CI 流程中的部署前检查。

我们已经有了一个使用PackagedProgram该类来获取 JSON 格式的“预览计划”的过程。不幸的是，这不包括有关分配的 UUID（或缺少 UUID）的任何信息。

PlanJSONDumpGenerator深入研究生成JSON 预览计划DumpableNode<?>（

定义作业时（使用 DataStream API），UUID 分配在StreamTransformation<T>. 反正有没有把PackagedProgram后面的数据连接到原来StreamTransformation<T>的s上来获取UUID？

还是有更好的方法来进行这种类型的验证？

标签： apache-flinkflink-streaming