错误描述

以 per-job cluster模式（yarn-cluster） 执行，如下：

flink run -m yarn-cluster /program/flink-1.12.5/examples/batch/WordCount.jar --input hdfs://hadoop1:8020/test2/a.txt --output hdfs://hadoop1:8020/flink_result11

过几分钟后，会报错，如下图：

很可能是 输出文件：hdfs://hadoop1:8020/flink_result11 已经存在，无法创建，导致的错误

但在控制台中显示的是上面的错误