Skip to content

Commit 3c07e82

Browse files
committed
Fix null check when fetching driverJars from value provider
1 parent feb9cda commit 3c07e82

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

  • sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc

sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -705,9 +705,12 @@ public DataSource buildDatasource() {
705705
basicDataSource.setDriverClassLoader(getDriverClassLoader());
706706
}
707707
if (getDriverJars() != null) {
708-
URLClassLoader classLoader =
709-
URLClassLoader.newInstance(JdbcUtil.saveFilesLocally(getDriverJars().get()));
710-
basicDataSource.setDriverClassLoader(classLoader);
708+
String driverJars = getDriverJars().get();
709+
if (!Strings.isNullOrEmpty(driverJars)) {
710+
URLClassLoader classLoader =
711+
URLClassLoader.newInstance(JdbcUtil.saveFilesLocally(driverJars));
712+
basicDataSource.setDriverClassLoader(classLoader);
713+
}
711714
}
712715

713716
return basicDataSource;

0 commit comments

Comments
 (0)