From c20dc0ce4b2e24425b604a7fd193aaa93e4865ce Mon Sep 17 00:00:00 2001 From: "cheney.yin" Date: Thu, 6 Apr 2023 15:05:44 +0800 Subject: [PATCH] [Improve][Transforms-v2][ZetaSQLEngine] Remove redundancy code in validateSQL --- .../seatunnel/transform/sqlengine/zeta/ZetaSQLEngine.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) 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();