From 85e8776a1035da92624c3561afef2b6f0e4034ed Mon Sep 17 00:00:00 2001 From: Mayur Singal <39544459+ulixius9@users.noreply.github.com> Date: Wed, 28 May 2025 16:10:59 +0530 Subject: [PATCH] Fix #17799: Doris ingestion failed (#21420) --- .../src/metadata/ingestion/source/database/doris/metadata.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/ingestion/src/metadata/ingestion/source/database/doris/metadata.py b/ingestion/src/metadata/ingestion/source/database/doris/metadata.py index 56aa3202e35..5f49b6d4bf4 100644 --- a/ingestion/src/metadata/ingestion/source/database/doris/metadata.py +++ b/ingestion/src/metadata/ingestion/source/database/doris/metadata.py @@ -60,6 +60,7 @@ RELKIND_MAP = { "Doris": TableType.Regular, "View": TableType.View, "MEMORY": TableType.View, + "OLAP": TableType.MaterializedView, } 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,... """ 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( sql.text(DORIS_GET_TABLE_NAMES), {"schema": schema_name} )