我的解决方式是改下 flink 的源码。

把参数 CliFrontend的args 传给 FlinkYarnSessionCli 类。并将args中的这些kv赋给configuration。

再重新打dist包



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复