diff --git a/debezium-connector-db2/src/main/java/io/debezium/connector/db2/Db2Connection.java b/debezium-connector-db2/src/main/java/io/debezium/connector/db2/Db2Connection.java
index 6fc878035..664b989c9 100644
--- a/debezium-connector-db2/src/main/java/io/debezium/connector/db2/Db2Connection.java
+++ b/debezium-connector-db2/src/main/java/io/debezium/connector/db2/Db2Connection.java
@@ -40,7 +40,7 @@
  */
 public class Db2Connection extends JdbcConnection {
 
-    private static final String GET_DATABASE_NAME = "SELECT CURRENT_SERVER FROM SYSIBM.SYSDUMMY1"; // DB2
+    private static final String GET_DATABASE_NAME = "SELECT CURRENT SERVER FROM SYSIBM.SYSDUMMY1"; // DB2
 
     private static Logger LOGGER = LoggerFactory.getLogger(Db2Connection.class);
 
diff --git a/debezium-connector-db2/src/test/docker/db2-cdc-docker/asncdcaddremove.sql b/debezium-connector-db2/src/test/docker/db2-cdc-docker/asncdcaddremove.sql
index 73d0aa61a..314532a08 100644
--- a/debezium-connector-db2/src/test/docker/db2-cdc-docker/asncdcaddremove.sql
+++ b/debezium-connector-db2/src/test/docker/db2-cdc-docker/asncdcaddremove.sql
@@ -181,9 +181,9 @@ SET stmtSQL =   'INSERT INTO ASNCDC.IBMSNAP_PRUNCNTL ( ' ||
                 '0, ' || 
                 '''KAFKAQUAL'', ' || 
                 '''SET001'', ' || 
-                ' (Select CURRENT_SERVER from sysibm.sysdummy1 ), ' || 
+                ' (Select CURRENT SERVER from sysibm.sysdummy1 ), ' || 
                 '8, ' || 
-                ' (Select CURRENT_SERVER from sysibm.sysdummy1 ), ' || 
+                ' (Select CURRENT SERVER from sysibm.sysdummy1 ), ' || 
                 '''ASNCDC'', ' || 
                 '''"CDC_' ||  tableschema ||  '_' || tablename || '"'', ' ||
                 ' ( SELECT CASE WHEN max(CAST(MAP_ID AS INT)) IS NULL THEN CAST(1 AS VARCHAR(10)) ELSE CAST(CAST(max(MAP_ID) AS INT) + 1 AS VARCHAR(10))  END AS MYINT from  ASNCDC.IBMSNAP_PRUNCNTL ) ' ||