From dfebc85c4e34f4e13d732665e106cc97b4ae1815 Mon Sep 17 00:00:00 2001 From: Mayur Singal <39544459+ulixius9@users.noreply.github.com> Date: Thu, 17 Feb 2022 10:46:23 +0530 Subject: [PATCH] fix #2790: fixed usage ingestion issue (#2805) --- ingestion/src/metadata/ingestion/bulksink/metadata_usage.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py b/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py index efab30f3ad3..1f0c590fdb6 100644 --- a/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py +++ b/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py @@ -74,7 +74,9 @@ class MetadataUsageBulkSink(BulkSink): for record in usage_records: table_usage = TableUsageCount(**json.loads(record)) if "." in table_usage.table: - table_usage.table = table_usage.table.split(".")[1] + table_usage.database, table_usage.table = table_usage.table.split(".")[ + -2: + ] self.service_name = table_usage.service_name table_entity = self.__get_table_entity( table_usage.database, table_usage.table