Apache Iceberg version
1.11.0 (latest release)
Query engine
None
Please describe the bug 🐞
This is a small regression introduced in the very last commit against RecordUtils.java.
In the method RecordUtils.createTableWriter():
This was changed:
- List<String> idCols = config.tableConfig(tableName).idColumns();
+ List<String> idCols = config.tableConfig(tableReference.identifier().name()).idColumns();
But it should be the following, since the "namespace" portion of the original tableName is now lost:
List<String> idCols = config.tableConfig(tableReference.identifier().toString()).idColumns();
This can easily be verified by comparing .toString() with .name() in TableIdentifier.
Also other code example show the correct usage:
For example in Coordinator.java, the table config is read correctly:
String branch = config.tableConfig(tableIdentifier.toString()).commitBranch();
Willingness to contribute
Apache Iceberg version
1.11.0 (latest release)
Query engine
None
Please describe the bug 🐞
This is a small regression introduced in the very last commit against RecordUtils.java.
In the method RecordUtils.createTableWriter():
This was changed:
But it should be the following, since the "namespace" portion of the original tableName is now lost:
This can easily be verified by comparing .toString() with .name() in TableIdentifier.
Also other code example show the correct usage:
For example in Coordinator.java, the table config is read correctly:
Willingness to contribute