yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-26 17:34:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix #17799: Doris ingestion failed (#21420)

Browse Source
This commit is contained in:
Mayur Singal 2025-05-28 16:10:59 +05:30 committed by GitHub
parent dd689d4aa8
commit 85e8776a10
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
ingestion/src/metadata/ingestion/source/database/doris/metadata.py
View File

@ -60,6 +60,7 @@ RELKIND_MAP = {
"Doris": TableType.Regular, "Doris": TableType.Regular,
"View": TableType.View, "View": TableType.View,
"MEMORY": TableType.View, "MEMORY": TableType.View,
"OLAP": TableType.MaterializedView,
} }
DorisDialect.get_table_names_and_type = get_table_names_and_type DorisDialect.get_table_names_and_type = get_table_names_and_type
@ -179,7 +180,9 @@ class DorisSource(CommonDbSourceService):
logic on how to handle table types, e.g., external, foreign,... logic on how to handle table types, e.g., external, foreign,...
""" """
tables = [ tables = [
TableNameAndType(name=name, type_=RELKIND_MAP.get(engine)) TableNameAndType(
name=name, type_=RELKIND_MAP.get(engine, TableType.Regular)
)
for name, engine in self.connection.execute( for name, engine in self.connection.execute(
sql.text(DORIS_GET_TABLE_NAMES), {"schema": schema_name} sql.text(DORIS_GET_TABLE_NAMES), {"schema": schema_name}
) )