Skip to content

Commit 64fdead

Browse files
comments
1 parent 7f2d288 commit 64fdead

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

xtable-core/src/main/java/org/apache/xtable/iceberg/IcebergConversionSource.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -120,6 +120,11 @@ public InternalTable getTable(Snapshot snapshot) {
120120
irPartitionFields.size() > 0
121121
? DataLayoutStrategy.HIVE_STYLE_PARTITION
122122
: DataLayoutStrategy.FLAT;
123+
// When the table name is not explicitly specified, Iceberg assumes the table is HDFS-based,
124+
// treating the table name as the location in HDFS. This assumption can lead to mismatches
125+
// during data conversion. To mitigate this issue, we rely on the table name provided in the
126+
// source configuration of the conversation, ensuring consistency and avoiding potential errors.
127+
// See https://github.com/apache/incubator-xtable/issues/494
123128
return InternalTable.builder()
124129
.tableFormat(TableFormat.ICEBERG)
125130
.basePath(iceTable.location())

0 commit comments

Comments
 (0)