diff --git a/src/test/java/io/debezium/connector/db2/Db2ReselectColumnsProcessorIT.java b/src/test/java/io/debezium/connector/db2/Db2ReselectColumnsProcessorIT.java
index 19028ae..a679641 100644
--- a/src/test/java/io/debezium/connector/db2/Db2ReselectColumnsProcessorIT.java
+++ b/src/test/java/io/debezium/connector/db2/Db2ReselectColumnsProcessorIT.java
@@ -30,7 +30,7 @@ public void beforeEach() throws Exception {
 
         TestHelper.disableDbCdc(connection);
         TestHelper.disableTableCdc(connection, "dbz4321");
-        connection.execute("DROP TABLE IF EXIST dbz4321");
+        connection.execute("DROP TABLE IF EXISTS dbz4321");
 
         connection.execute("DELETE FROM ASNCDC.IBMSNAP_REGISTER");