yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-10 07:53:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix hive get table issue with impala (#10424)

Browse Source 
* Fix hive get table issue with impala

* Fix Lint
This commit is contained in:
Mayur Singal 2023-03-06 15:59:54 +05:30 committed by GitHub
parent 895e7d2706
commit f7a7a16cdb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ingestion/src/metadata/ingestion/source/database/hive/metadata.py
View File

@ -15,7 +15,6 @@ Hive source methods.
import re import re
from typing import Tuple from typing import Tuple
from impala.sqlalchemy import ImpalaDialect
from pyhive.sqlalchemy_hive import HiveDialect, _type_map from pyhive.sqlalchemy_hive import HiveDialect, _type_map
from sqlalchemy import types, util from sqlalchemy import types, util
from sqlalchemy.engine import reflection from sqlalchemy.engine import reflection
@ -185,7 +184,6 @@ def get_table_comment( # pylint: disable=unused-argument
HiveDialect.get_columns = get_columns HiveDialect.get_columns = get_columns
HiveDialect.get_table_comment = get_table_comment HiveDialect.get_table_comment = get_table_comment
ImpalaDialect.get_table_comment = get_table_comment
HIVE_VERSION_WITH_VIEW_SUPPORT = "2.2.0" HIVE_VERSION_WITH_VIEW_SUPPORT = "2.2.0"
@ -225,10 +223,6 @@ class HiveSource(CommonDbSourceService):
): ):
HiveDialect.get_table_names = get_table_names HiveDialect.get_table_names = get_table_names
HiveDialect.get_view_names = get_view_names HiveDialect.get_view_names = get_view_names
ImpalaDialect.get_table_names = get_table_names
ImpalaDialect.get_table_names = get_view_names
else: else:
HiveDialect.get_table_names = get_table_names_older_versions HiveDialect.get_table_names = get_table_names_older_versions
HiveDialect.get_view_names = get_view_names_older_versions HiveDialect.get_view_names = get_view_names_older_versions
ImpalaDialect.get_table_names = get_table_names_older_versions
ImpalaDialect.get_table_names = get_view_names_older_versions