diff --git a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sqlengine/zeta/ZetaSQLEngine.java b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sqlengine/zeta/ZetaSQLEngine.java
index a1a77788cae..18161e08605 100644
--- a/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sqlengine/zeta/ZetaSQLEngine.java
+++ b/seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sqlengine/zeta/ZetaSQLEngine.java
@@ -89,10 +89,7 @@ private void validateSQL(Statement statement) {
             }
             Select select = (Select) statement;
             if (!(select.getSelectBody() instanceof PlainSelect)) {
-                throw new IllegalArgumentException("Unsupported SQL syntax: %s");
-            }
-            if (!(select.getSelectBody() instanceof PlainSelect)) {
-                throw new IllegalArgumentException("Unsupported SQL syntax: %s");
+                throw new IllegalArgumentException("Unsupported SQL syntax");
             }
             PlainSelect selectBody = (PlainSelect) select.getSelectBody();