You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by fa...@apache.org on 2023/04/07 02:58:48 UTC

[incubator-seatunnel] branch dev updated: [Improve][Transforms-v2][ZetaSQLEngine] Remove redundancy code in validateSQL (#4506)

This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new d2313682e [Improve][Transforms-v2][ZetaSQLEngine] Remove redundancy code in validateSQL (#4506)
d2313682e is described below

commit d2313682eae4e238f7757b1cfe635c1baa617896
Author: Chengyu Yan <ch...@hotmail.com>
AuthorDate: Fri Apr 7 10:58:41 2023 +0800

    [Improve][Transforms-v2][ZetaSQLEngine] Remove redundancy code in validateSQL (#4506)
---
 .../org/apache/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 a1a77788c..18161e086 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 @@ public class ZetaSQLEngine implements SQLEngine {
             }
             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();