diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/OpenMetadataApplicationConfig.java b/openmetadata-service/src/main/java/org/openmetadata/service/OpenMetadataApplicationConfig.java index 4a271b52e18..4e253bfab45 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/OpenMetadataApplicationConfig.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/OpenMetadataApplicationConfig.java @@ -18,7 +18,7 @@ import io.dropwizard.Configuration; import io.dropwizard.db.DataSourceFactory; import io.dropwizard.health.conf.HealthConfiguration; import io.federecio.dropwizard.swagger.SwaggerBundleConfiguration; -import java.util.LinkedHashMap; +import java.util.Map; import javax.validation.Valid; import javax.validation.constraints.NotNull; import lombok.Getter; @@ -36,6 +36,7 @@ import org.openmetadata.schema.service.configuration.elasticsearch.ElasticSearch import org.openmetadata.service.config.OMWebConfiguration; import org.openmetadata.service.migration.MigrationConfiguration; import org.openmetadata.service.monitoring.EventMonitorConfiguration; +import org.openmetadata.service.util.JsonUtils; @Getter @Setter @@ -70,8 +71,9 @@ public class OpenMetadataApplicationConfig extends Configuration { public PipelineServiceClientConfiguration getPipelineServiceClientConfiguration() { if (pipelineServiceClientConfiguration != null) { - LinkedHashMap temporarySSLConfig = - (LinkedHashMap) pipelineServiceClientConfiguration.getSslConfig(); + Map temporarySSLConfig = + JsonUtils.readOrConvertValue( + pipelineServiceClientConfiguration.getSslConfig(), Map.class); if (temporarySSLConfig != null && temporarySSLConfig.containsKey(CERTIFICATE_PATH)) { temporarySSLConfig.put("caCertificate", temporarySSLConfig.get(CERTIFICATE_PATH)); temporarySSLConfig.remove(CERTIFICATE_PATH);