Fix #1116: make elastic search database not include FQN (#1126)

This commit is contained in:
Sriharsha Chintalapani 2021-11-09 23:34:56 -08:00 committed by GitHub
parent 58460f3f2b
commit cc539f37fd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -221,7 +221,7 @@ class ElasticsearchSink(Sink):
table_followers.append(str(follower.id.__root__))
table_doc = TableESDocument(
table_id=str(table.id.__root__),
database=database,
database=str(database_entity.name.__root__),
service=service_entity.name,
service_type=service_entity.serviceType.name,
table_name=table.name.__root__,