我正在尝试通过使用BucketingSink和自定义ParquetSinkWriter在HDFS上使用Apache Flink编写Parquet文件。 这是代码,上面的错误指示从下面开始启用检查点(在BucketingSink类中调用snapshotState())刷新方法时无法正常工作。甚至writer也被“ writer.close();”关闭。但仍然收到来自“ writer = createWriter();”的错误。有什么想法吗?谢谢 得到这样的错误: org.apache.hadoop.fs.FileAl…