diff --git a/core/src/main/java/org/apache/iceberg/FastAppend.java b/core/src/main/java/org/apache/iceberg/FastAppend.java index 49cdef12996d..499f7b2c46e5 100644 --- a/core/src/main/java/org/apache/iceberg/FastAppend.java +++ b/core/src/main/java/org/apache/iceberg/FastAppend.java @@ -149,12 +149,12 @@ private ManifestFile copyManifest(ManifestFile manifest) { @Override public List apply(TableMetadata base, Snapshot snapshot) { - List newManifests = Lists.newArrayList(); + List allNewManifests = Lists.newArrayList(); try { List manifests = writeManifests(); if (manifests != null) { - newManifests.addAll(manifests); + allNewManifests.addAll(manifests); } } catch (IOException e) { throw new RuntimeIOException(e, "Failed to write manifest"); @@ -164,13 +164,13 @@ public List 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