FlinkFlink on yarn 使用 pre-job模式 提交任务kerberos 认证 源码代码解读

Posted 2022-12-01 九师兄

文章目录

• 1.概述
• 2.源码解析
• • 2.1 提交阶段
  • 2.2 创建安全的线程环境
  • • 2.2.1 创建SecurityConfiguration
  • 2.2 install模块
  • • 2.2.1 安装安全模块
    • • 2.2.1.1 findModuleFactory
      • 2.2.1.2 createModule
      • • 2.2.1.2.1 HadoopModuleFactory
        • 2.2.1.2.1 创建 HadoopModule
      • 2.2.1.2 安装module
    • 2.2.2 安装安全上下文
  • 2.4 提交阶段
  • • 2.4.1 deployInternal源码
    • <