diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/util/OpenMetadataOperations.java b/openmetadata-service/src/main/java/org/openmetadata/service/util/OpenMetadataOperations.java index 90d39a8fe15..992f3990296 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/util/OpenMetadataOperations.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/util/OpenMetadataOperations.java @@ -783,7 +783,7 @@ public class OpenMetadataOperations implements Callable { App app = appRepository.getByName(null, appName, appRepository.getFields("id")); EventPublisherJob config = - ((EventPublisherJob) app.getAppConfiguration()) + (JsonUtils.convertValue(app.getAppConfiguration(), EventPublisherJob.class)) .withEntities(entities) .withBatchSize(batchSize) .withPayLoadSize(payloadSize) @@ -869,7 +869,7 @@ public class OpenMetadataOperations implements Callable { appRepository.getByName(null, "DataInsightsApplication", appRepository.getFields("id")); DataInsightsAppConfig config = - ((DataInsightsAppConfig) app.getAppConfiguration()) + JsonUtils.convertValue(app.getAppConfiguration(), DataInsightsAppConfig.class) .withBatchSize(batchSize) .withRecreateDataAssetsIndex(recreateIndexes) .withBackfillConfiguration(backfillConfiguration);