fix(ingest): prevent NullPointerException when non-jdbc SaveIntoDataSourceCommand (#6803)

This commit is contained in:
danielli-ziprecruiter 2022-12-19 09:41:06 -07:00 committed by GitHub
parent 6f71c957d5
commit 7ca21a8e7c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -143,7 +143,7 @@ public class DatasetExtractor {
SaveIntoDataSourceCommand cmd = (SaveIntoDataSourceCommand) p;
Map<String, String> options = JavaConversions.mapAsJavaMap(cmd.options());
String url = options.get("url"); // e.g. jdbc:postgresql://localhost:5432/sparktestdb
String url = options.getOrDefault("url", ""); // e.g. jdbc:postgresql://localhost:5432/sparktestdb
if (!url.contains("jdbc")) {
return Optional.empty();
}