Skip to content

Commit af1c864

Browse files
fix file sequence number assertion by duckdb
Signed-off-by: Aykut Bozkurt <aykut.bozkurt@snowflake.com>
1 parent f4a7307 commit af1c864

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

pg_lake_iceberg/src/iceberg/metadata_operations.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1145,8 +1145,8 @@ CreateIcebergManifestEntryFromMetadataOperation(TableMetadataOperation * operati
11451145
manifestEntry->has_sequence_number = true;
11461146
manifestEntry->sequence_number = sequenceNumber;
11471147

1148-
manifestEntry->file_sequence_number = 0;
1149-
manifestEntry->has_file_sequence_number = false;
1148+
manifestEntry->file_sequence_number = sequenceNumber;
1149+
manifestEntry->has_file_sequence_number = true;
11501150

11511151
SetIcebergDataFileStats(&operation->dataFileStats,
11521152
&manifestEntry->data_file.record_count,

pg_lake_iceberg/src/iceberg/write_manifest.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -219,7 +219,7 @@ WriteIcebergManifestEntryToAvro(IcebergManifestEntry * entry, avro_value_t * rec
219219
AvroSetInt32Field(record, "status", entry->status);
220220
AvroSetNullableInt64Field(record, "snapshot_id", entry->snapshot_id, entry->has_snapshot_id);
221221
AvroSetNullableInt64Field(record, "sequence_number", entry->sequence_number, entry->has_sequence_number);
222-
AvroSetNullableInt64Field(record, "file_sequence_number", entry->sequence_number, entry->has_file_sequence_number);
222+
AvroSetNullableInt64Field(record, "file_sequence_number", entry->file_sequence_number, entry->has_file_sequence_number);
223223
AvroSetRecordField(record, "data_file", (AvroSerializeFunction) WriteDataFileToAvro, &entry->data_file);
224224
}
225225

0 commit comments

Comments
 (0)