fix #2790: fixed usage ingestion issue (#2805)

This commit is contained in:
Mayur Singal 2022-02-17 10:46:23 +05:30 committed by GitHub
parent 8555966f61
commit dfebc85c4e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -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