flink-core/src/main/java/org/apache/flink/core/fs/local/LocalRecoverableSerializer.java
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableSerializer.java

flink-core/src/main/java/org/apache/flink/core/fs/local/LocalRecoverableWriter.java
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableWriter.java