We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 7995a5e + 3c07e82 commit 2f79185Copy full SHA for 2f79185
1 file changed
sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java
@@ -705,9 +705,12 @@ public DataSource buildDatasource() {
705
basicDataSource.setDriverClassLoader(getDriverClassLoader());
706
}
707
if (getDriverJars() != null) {
708
- URLClassLoader classLoader =
709
- URLClassLoader.newInstance(JdbcUtil.saveFilesLocally(getDriverJars().get()));
710
- basicDataSource.setDriverClassLoader(classLoader);
+ String driverJars = getDriverJars().get();
+ if (!Strings.isNullOrEmpty(driverJars)) {
+ URLClassLoader classLoader =
711
+ URLClassLoader.newInstance(JdbcUtil.saveFilesLocally(driverJars));
712
+ basicDataSource.setDriverClassLoader(classLoader);
713
+ }
714
715
716
return basicDataSource;
0 commit comments