LocalExecutor执行job时通过构建一个MiniCluster来完成job的执行，MiniCluster的启动可以简洁的归纳为三个步骤
a、设置conf参数
b、构建MiniCluster对象
c、启动并完成个组件的初始化
下面具体来看：
1、LocalExecutor.startMiniCluster方法
MiniCluster是local模式运行的环境，包含flink运行时组件：作业管理器（JobManager）、资源管理器（ResourceManager）、任务管理器（TaskManager）和分发器（dispatcher）以及一些其他组件，在该方法中仅new了一个MiniCluster对象，其组件的初始化在start中完成。
2、MiniCluster.start方法
实例化RpcService
实例化和启动各类组件
MiniCluster就是local模式执行的环境，此处暂先不做深入分析
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
