我正在努力改进 apache flink 的资源和任务调度,请分享任何关于 Apache flink 内部架构的教程或任何文档。还分享调试 flink 代码的正确方法。
感谢您在分析flink代码方面的帮助和经验。
对于 Flink 中作业调度的工作原理,我会开始研究 https://ci.apache.org/projects/flink/flink-docs-release-1.2/internals/job_scheduling.html。通常,当前 Flink 文档的最后一部分包含了一些关于 Apache Flink 内部的好信息。