yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2026-01-07 21:16:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add Null check for source config (#18746)

Browse Source
This commit is contained in:
Mohit Yadav 2024-11-22 17:34:12 +05:30 committed by GitHub
parent 582a10c831
commit 51f3591714
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/IngestionPipelineRepository.java
View File

@ -94,11 +94,14 @@ public class IngestionPipelineRepository extends EntityRepository<IngestionPipel
? getLatestPipelineStatus(ingestionPipeline)
: ingestionPipeline.getPipelineStatuses());
JSONObject sourceConfigJson =
new JSONObject(JsonUtils.pojoToJson(ingestionPipeline.getSourceConfig().getConfig()));
Optional.ofNullable(sourceConfigJson.optJSONObject("appConfig"))
.map(appConfig -> appConfig.optString("type", null))
.ifPresent(ingestionPipeline::setApplicationType);
if (ingestionPipeline.getSourceConfig() != null
&& ingestionPipeline.getSourceConfig().getConfig() != null) {
JSONObject sourceConfigJson =
new JSONObject(JsonUtils.pojoToJson(ingestionPipeline.getSourceConfig().getConfig()));
Optional.ofNullable(sourceConfigJson.optJSONObject("appConfig"))
.map(appConfig -> appConfig.optString("type", null))
.ifPresent(ingestionPipeline::setApplicationType);
}
}
@Override