Question

实现 FileSystem 必须是线程安全的：相同的实例 FileSystem 经常在 Flink 中的多个线程之间共享，并且必须能够同时创建输入/输出流和列表文件元数据。

这些 FSDataOutputStream 和 FSDataOutputStream 实现严格地说 不是线程安全的 。在读取或写入 算子操作之间的线程之间也不应传递流的实例，因为不能保证跨线程的 算子操作的可见性（许多 算子操作不会创建内存防护）。