This is an automated email from the ASF dual-hosted git repository.
fokko 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 5e1897c20b Python: Pass through the location for the FileIO (#5709)
5e1897c20b is described below
commit 5e1897c20b91c0f48c61fd8183de3de505e60bd9
Author: Fokko Driesprong <[email protected]>
AuthorDate: Tue Sep 6 16:00:28 2022 +0200
Python: Pass through the location for the FileIO (#5709)
This way we can determine to load the correct FileIO
---
python/pyiceberg/catalog/hive.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/python/pyiceberg/catalog/hive.py b/python/pyiceberg/catalog/hive.py
index 2ffbe66a99..1edba2d76e 100644
--- a/python/pyiceberg/catalog/hive.py
+++ b/python/pyiceberg/catalog/hive.py
@@ -352,7 +352,7 @@ class HiveCatalog(Catalog):
except NoSuchObjectException as e:
raise NoSuchTableError(f"Table does not exists: {table_name}")
from e
- io = load_file_io({**self.properties, **hive_table.parameters})
+ io = load_file_io({**self.properties, **hive_table.parameters},
hive_table.sd.location)
return self._convert_hive_into_iceberg(hive_table, io)
def drop_table(self, identifier: Union[str, Identifier]) -> None:
