fix polardbxSourceITCase

apache · Aug 10, 2022 · 348cac0 · 348cac0
1 parent dbfa254
commit 348cac0
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...-mysql-cdc/src/test/java/com/ververica/cdc/connectors/polardbx/PolardbxCharsetITCase.java b/...-mysql-cdc/src/test/java/com/ververica/cdc/connectors/polardbx/PolardbxCharsetITCase.java
@@ -372,7 +372,10 @@ public void testCharset() throws Exception {
         // test binlog phase
         try (Connection connection = getJdbcConnection();
                 Statement statement = connection.createStatement()) {
-            statement.execute(String.format("UPDATE %s SET table_id = table_id + 10;", testName));
+            statement.execute(
+                    String.format(
+                            "/*TDDL:FORBID_EXECUTE_DML_ALL=FALSE*/UPDATE %s.%s SET table_id = table_id + 10;",
+                            DATABASE, testName));
         }
         assertEqualsInAnyOrder(
                 Arrays.asList(binlogExpected), fetchRows(iterator, binlogExpected.length));