You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by bl...@apache.org on 2020/06/03 04:30:43 UTC
[iceberg] branch master updated: Use correct spec while merging
manifests in MergingSnapshotProducer (#1089)
This is an automated email from the ASF dual-hosted git repository.
blue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/master by this push:
new 01c8162 Use correct spec while merging manifests in MergingSnapshotProducer (#1089)
01c8162 is described below
commit 01c8162f7b45b784b8f25fa7ee6a55f51102e154
Author: Anton Okolnychyi <ao...@apple.com>
AuthorDate: Tue Jun 2 21:30:34 2020 -0700
Use correct spec while merging manifests in MergingSnapshotProducer (#1089)
---
core/src/main/java/org/apache/iceberg/MergingSnapshotProducer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/java/org/apache/iceberg/MergingSnapshotProducer.java b/core/src/main/java/org/apache/iceberg/MergingSnapshotProducer.java
index 8e905f0..dad5018 100644
--- a/core/src/main/java/org/apache/iceberg/MergingSnapshotProducer.java
+++ b/core/src/main/java/org/apache/iceberg/MergingSnapshotProducer.java
@@ -670,7 +670,7 @@ abstract class MergingSnapshotProducer<ThisT> extends SnapshotProducer<ThisT> {
return mergeManifests.get(bin);
}
- ManifestWriter<DataFile> writer = newManifestWriter(ops.current().spec());
+ ManifestWriter<DataFile> writer = newManifestWriter(ops.current().spec(specId));
try {
for (ManifestFile manifest : bin) {
try (ManifestReader reader = ManifestFiles.read(manifest, ops.io(), ops.current().specsById())) {