[Bug]: not set Clickhouse userName and password have npe #134

Author: ConradJam

flink-connector-clickhouse/src/main/java/org/apache/flink/connector/clickhouse/internal/connection/ClickHouseConnectionProvider.java

@@ -128,10 +128,14 @@ private ClickHouseConnection createConnection(String url, String database) throw
         LOG.info("connecting to {}, database {}", url, database);
         Properties configuration = new Properties();
         configuration.putAll(connectionProperties);
-        configuration.setProperty(
-                ClickHouseDefaults.USER.getKey(), options.getUsername().orElse(null));
-        configuration.setProperty(
-                ClickHouseDefaults.PASSWORD.getKey(), options.getPassword().orElse(null));
+        if (options.getUsername().isPresent()) {
+            configuration.setProperty(
+                    ClickHouseDefaults.USER.getKey(), options.getUsername().get());
+        }
+        if (options.getPassword().isPresent()) {
+            configuration.setProperty(
+                    ClickHouseDefaults.PASSWORD.getKey(), options.getPassword().get());
+        }
         ClickHouseDriver driver = new ClickHouseDriver();
         return driver.connect(url, configuration);
     }

pom.xml

@@ -58,10 +58,10 @@ limitations under the License.
 
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-		<maven.compiler.source>11</maven.compiler.source>
-		<maven.compiler.target>11</maven.compiler.target>
+		<maven.compiler.source>8</maven.compiler.source>
+		<maven.compiler.target>8</maven.compiler.target>
 		<junit.version>4.13.2</junit.version>
-		<clickhouse-jdbc.version>0.6.0-patch3</clickhouse-jdbc.version>
+		<clickhouse-jdbc.version>0.6.1</clickhouse-jdbc.version>
 		<scala.binary.version>2.12</scala.binary.version>
 		<flink.version>1.19.0</flink.version>
 		<flink.scope>provided</flink.scope>