本文解析了Flink在Kubernetes上的实现原理，主要分析了Session模式的集群创建流程。启动入口为KubernetesSessionCli，通过KubernetesClusterDescriptor创建集群，最终返回RestClusterClient用于集群交互。重点剖析了JobManager Pod的初始化过程，包括各类Decorator如何定义资源配置和伴生对象。同时对比了Sess

Source执行时由SourceOperatorCoordinator和SourceReader两部分组成，SourceOperatorCoordinator执行SourceSplitEnumerator逻辑，管理SourceSplit， 将SourceSplit分配给SourceReader；SourceReader是SourceOperator在启动时创建，SourceOperator和Sou

Flink CDC的MySqlSource组件通过MySqlSourceEnumerator和MySqlSourceReader实现MySQL数据的全量和增量同步。MySqlSourceEnumerator采用两种分片策略：MySqlBinlogSplitAssigner处理增量数据，MySqlHybridSplitAssigner先通过均分算法切分全量快照数据，再创建BinlogSplit读取增

一步一步亲身实践总结