diff --git a/test/src/test/java/com/oceanbase/test/LogProxyCETest.java b/test/src/test/java/com/oceanbase/test/LogProxyCETest.java
index 52ff6c4..9419f0f 100644
--- a/test/src/test/java/com/oceanbase/test/LogProxyCETest.java
+++ b/test/src/test/java/com/oceanbase/test/LogProxyCETest.java
@@ -192,6 +192,13 @@ public void onException(LogProxyClientException e) {
         Assertions.assertEquals("1", fieldMap.get("id"));
         Assertions.assertEquals("meat", fieldMap.get("name"));
 
+        try (Connection conn = driver.connect("jdbc:mysql://" + observerIP + ":2881/test", props);
+                Statement statement = conn.createStatement()) {
+            statement.execute("DROP TABLE t_product");
+        } catch (SQLException e) {
+            Assertions.fail(e);
+        }
+
         client.stop();
     }
 }