Skip to content

Commit

Permalink
fixes codestyle
Browse files Browse the repository at this point in the history
  • Loading branch information
ConeyLiu committed Jun 2, 2023
1 parent 617647e commit 9074d09
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions core/src/main/java/org/apache/iceberg/FastAppend.java
Expand Up @@ -149,12 +149,12 @@ private ManifestFile copyManifest(ManifestFile manifest) {

@Override
public List<ManifestFile> apply(TableMetadata base, Snapshot snapshot) {
List<ManifestFile> newManifests = Lists.newArrayList();
List<ManifestFile> allNewManifests = Lists.newArrayList();

try {
List<ManifestFile> manifests = writeManifests();
if (manifests != null) {
newManifests.addAll(manifests);
allNewManifests.addAll(manifests);
}
} catch (IOException e) {
throw new RuntimeIOException(e, "Failed to write manifest");
Expand All @@ -164,13 +164,13 @@ public List<ManifestFile> apply(TableMetadata base, Snapshot snapshot) {
Iterables.transform(
Iterables.concat(appendManifests, rewrittenAppendManifests),
manifest -> GenericManifestFile.copyOf(manifest).withSnapshotId(snapshotId()).build());
Iterables.addAll(newManifests, appendManifestsWithMetadata);
Iterables.addAll(allNewManifests, appendManifestsWithMetadata);

if (snapshot != null) {
newManifests.addAll(snapshot.allManifests(ops.io()));
allNewManifests.addAll(snapshot.allManifests(ops.io()));
}

return newManifests;
return allNewManifests;
}

@Override
Expand Down

0 comments on commit 9074d09

Please sign in to comment.