fix: trim strings for null-safety

locchipinti · locchipinti · commit 6c86decee09d · 2026-04-05T22:58:26.000+02:00
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceConfigFactory.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceConfigFactory.java
@@ -94,7 +94,7 @@ public MySqlSourceConfigFactory hostname(String hostname) {
      */
     public MySqlSourceConfigFactory snapshotHostname(String snapshotHostname) {
         this.snapshotHostname =
-                (snapshotHostname != null && snapshotHostname.isEmpty()) ? null : snapshotHostname;
+                (snapshotHostname != null && snapshotHostname.trim().isEmpty()) ? null : snapshotHostname;
         return this;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -94,7 +94,7 @@ public MySqlSourceConfigFactory hostname(String hostname) {`
`94`	`94`	`*/`
`95`	`95`	`public MySqlSourceConfigFactory snapshotHostname(String snapshotHostname) {`
`96`	`96`	`this.snapshotHostname =`
`97`		`- (snapshotHostname != null && snapshotHostname.isEmpty()) ? null : snapshotHostname;`
	`97`	`+ (snapshotHostname != null && snapshotHostname.trim().isEmpty()) ? null : snapshotHostname;`
`98`	`98`	`return this;`
`99`	`99`	`}`
`100`	`100`