在保存checkpints的时候，可能会出现保存失败的情况。我遇到的报错如下：
Could not flush and close the file system output stream to hdfs:....
could only be replicated to 0 nodes instead of minReplication (=1). There are 2 datanode(s) running and no node(s) are excluded in this operation.
我的原因是flink-conf.yaml配置文件配置错误。
我只在一个节点上的flink-conf.yaml进行了如下配置，将所有节点上的配置文件都按如下修改，问题解决。
版权声明：本文不是「本站」原创文章，版权归原作者所有 | 原文地址: