我用 dop > 1 执行我的程序，但我不想要多个输出文件。在 Java 中，myDataSet.writeAsText(outputFilePath, WriteMode.OVERWRITE).setParallelism(1);按预期工作。
但是当我在 Python 中尝试相同的方法时，它不起作用。这是我的代码:myDataSet.write_text(output_file, write_mode=WriteMode.OVERWRITE).set_degree_of_parallelism(1)
是否有可能在 Python 中实现这种行为？
请您参考如下方法:
这不是错误，而是不受支持的功能。目前无法为单个算子设置并行度，只能为整个作业设置。
我为此打开了一个 JIRA:https://issues.apache.org/jira/browse/FLINK-3275
