diff --git a/flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2Dialect.java b/flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2Dialect.java
index 68ba6b1b7..2081376f9 100644
--- a/flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2Dialect.java
+++ b/flink-connector-jdbc-db2/src/main/java/org/apache/flink/connector/jdbc/db2/database/dialect/Db2Dialect.java
@@ -111,7 +111,7 @@ public Optional<String> getUpsertStatement(
                                         + " WHEN MATCHED THEN"
                                         + " UPDATE SET %s"
                                         + " WHEN NOT MATCHED THEN"
-                                        + " INSERT (%s) VALUES (%s);",
+                                        + " INSERT (%s) VALUES (%s)",
                                 quoteIdentifier(tableName),
                                 valuesBinding,
                                 columnBinding,