flink-1.11.2版本，客户端如何设置dynamic properties

[easonliu30624700]

CONTENTS DELETED

The author has deleted this message.

[easonliu30624700]

看FlinkYarnSessionCli代码：
                final Configuration configuration =
applyCommandLineOptionsToConfiguration(cmd);
                final ClusterClientFactory<ApplicationId> yarnClusterClientFactory =
clusterClientServiceLoader.getClusterClientFactory(configuration);
                configuration.set(DeploymentOptions.TARGET,
YarnDeploymentTarget.SESSION.getName());

                final YarnClusterDescriptor yarnClusterDescriptor =
(YarnClusterDescriptor)
yarnClusterClientFactory.createClusterDescriptor(configuration);

动态参数也是解析成key、value，传给configuration，最后在YarnClusterClientFactory工厂类里面创建YarnClusterDescriptor对象。

所以，当前动态参数设置不生效是bug，还是哪里使用姿势不对。有大佬能解答一下吗



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