This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 5a89d22c146 [FLINK-32131][python] Support specifying hadoop config
directory for HiveCatalog
5a89d22c146 is described below
commit 5a89d22c146f451f12fd0c6de64804d315e1f4b6
Author: Dian Fu <[email protected]>
AuthorDate: Fri May 19 13:54:53 2023 +0800
[FLINK-32131][python] Support specifying hadoop config directory for
HiveCatalog
This closes #22607.
---
flink-python/pyflink/table/catalog.py | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/flink-python/pyflink/table/catalog.py
b/flink-python/pyflink/table/catalog.py
index 9934d1747a5..d12c3fd193c 100644
--- a/flink-python/pyflink/table/catalog.py
+++ b/flink-python/pyflink/table/catalog.py
@@ -1164,13 +1164,14 @@ class HiveCatalog(Catalog):
A catalog implementation for Hive.
"""
- def __init__(self, catalog_name: str, default_database: str = None,
hive_conf_dir: str = None):
+ def __init__(self, catalog_name: str, default_database: str = None,
hive_conf_dir: str = None,
+ hadoop_conf_dir: str = None, hive_version: str = None):
assert catalog_name is not None
gateway = get_gateway()
j_hive_catalog =
gateway.jvm.org.apache.flink.table.catalog.hive.HiveCatalog(
- catalog_name, default_database, hive_conf_dir)
+ catalog_name, default_database, hive_conf_dir, hadoop_conf_dir,
hive_version)
super(HiveCatalog, self).__init__(j_hive_catalog)
