我正在docker上运行Flink1.2.1，任务管理器作为DockerSwarm的一部分分布在不同的虚拟机上。
使用flinkwebui上传apachebeam应用程序并尝试在作业提交点设置并行性是行不通的。也不使用flink cli提交作业。
似乎并行性在客户机级别没有得到提升，它最终默认为1。
当我在apache beam代码中以编程方式设置并行性时，它可以工作： flinkPipelineOptions.setParallelism(4); 我怀疑问题的根源可能在 org.apache.beam.runners.flink.DefaultParallelismFactory 类，因为它检查flink的globalconfiguration，该配置可能不会获取传递给flink的运行时值。
关于如何解决这个问题有什么想法吗？我需要能够动态地更改并行性，这样编程方法就不起作用了，在系统级设置flink配置也不起作用。
我正在使用以下文档：https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/parallel.htmlhttpshttp://beam.apache.org/documentation/sdks/javadoc/2.0.0/org/apache/beam/runners/flink/defaultparallelismfactory.html