diff --git a/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/operations/IngestionResource.java b/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/operations/IngestionResource.java index 0f60ff1ac54..f7dfad4649d 100644 --- a/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/operations/IngestionResource.java +++ b/catalog-rest-service/src/main/java/org/openmetadata/catalog/resources/operations/IngestionResource.java @@ -325,7 +325,7 @@ public class IngestionResource { }) public Ingestion triggerIngestion(@Context UriInfo uriInfo, @PathParam("id") String id, @Context SecurityContext securityContext) throws IOException, ParseException { - Fields fields = new Fields(FIELD_LIST, ""); + Fields fields = new Fields(FIELD_LIST, "owner"); Ingestion ingestion = dao.get(uriInfo, id, fields); airflowRESTClient.runPipeline(ingestion.getName()); return addHref(uriInfo, dao.get(uriInfo, id, fields));