@Override
    public DeltaManifests deserialize(int version, byte[] serialized) throws IOException {
        if (version == VERSION_1) {
            return deserializeV1(serialized);
        } else if (version == VERSION_2) {
            return deserializeV2(serialized);
        } else {
            throw new RuntimeException("Unknown serialize version: " + version);
        }
    }
Copy from iceberg-flink:iceberg-flink-1.15:1.3.1
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/DeltaManifestsSerializer.java