有三个客户端:https://www.yuque.com/manyanshanhe/qpg85l/gr4l95
在上一节当中的run方法下,查看此代码,点击validateAndGetActiveCommandLine 方法 查看哪个客户端活跃!点击 isActive 方法活跃的客户端顺序依次为 GenericCLI FlinkYarn Flink自带 点进去
GenericCLITest 方法查看继续点击
FlinkYarn方法查看
调用了一个抽象类NAME和 TARGET进行对比点击NAME -> PER_JOB点击TARGET 当这三个条件满足一个就可以了
默认方法查看(对着接口按住Ctrl + t,可以查看如下实现类)
他不做任何判断,当上面两个都用不了的时候,就用这个方法去提交
整体来讲就是这些