据我所知,检查点故障应该被忽略,并在可能更大的状态下重新尝试。我有过这种情况
状态待机不支持org.apache.hadoop.ipc.RemoteException(org.apache.hadoop.ipc.StandbyException):操作类别写入。在org.apache.flink.runtime.fs.hdfs.HadoopFileSystem.mkdirs(HadoopFileSystem.java:453) at org.ap
当我试图用flatMap操作符写出集合时,我得到了非法的状态异常(仅在高负载下):缓冲池被破坏了,我在这里做错了什么?当flink抛出缓冲池错误时?at org.apache.flink.streaming.runtime.io.RecordWriterOutput.pushToRecordWriter(RecordWriterOutput.java:110)
at org.apache.flink.streaming.runtime.io.RecordWriterOutput.