diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/ListFilter.java b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/ListFilter.java index 5be6f5ba58ed..5ca5528b422a 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/ListFilter.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/ListFilter.java @@ -125,9 +125,7 @@ public String getApiCollectionCondition(String apiEndpoint) { private String getEntityFQNHashCondition() { String entityFQN = getQueryParam("entityFQNHash"); - return entityFQN == null - ? "" - : String.format("entityFQNHash = :entityFQNHash", FullyQualifiedName.buildHash(entityFQN)); + return entityFQN == null ? "" : "entityFQNHash = :entityFQNHash"; } public String getParentCondition(String tableName) { diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/workflows/searchIndex/PaginatedEntityTimeSeriesSource.java b/openmetadata-service/src/main/java/org/openmetadata/service/workflows/searchIndex/PaginatedEntityTimeSeriesSource.java index a506695a0967..aeb4e5888f13 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/workflows/searchIndex/PaginatedEntityTimeSeriesSource.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/workflows/searchIndex/PaginatedEntityTimeSeriesSource.java @@ -17,6 +17,7 @@ import org.openmetadata.service.exception.SearchIndexException; import org.openmetadata.service.jdbi3.EntityTimeSeriesRepository; import org.openmetadata.service.jdbi3.ListFilter; +import org.openmetadata.service.util.FullyQualifiedName; import org.openmetadata.service.util.RestUtil; import org.openmetadata.service.util.ResultList; import org.openmetadata.service.workflows.interfaces.Source; @@ -145,7 +146,7 @@ public void updateStats(int currentSuccess, int currentFailed) { private ListFilter getFilter() { ListFilter filter = new ListFilter(null); if (ReindexingUtil.isDataInsightIndex(entityType)) { - filter.addQueryParam("entityFQNHash", entityType); + filter.addQueryParam("entityFQNHash", FullyQualifiedName.buildHash(entityType)); } return filter; }