[jira] [Commented] (FLINK-23810) Print sql when parse failed , which is convenient to find error sql from multiple executed sql

[hehuiyuan (Jira)]

    [ 
https://issues.apache.org/jira/browse/FLINK-23810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17399714#comment-17399714
 ] 

hehuiyuan commented on FLINK-23810:
-----------------------------------

 

 
{code:java}
    tableEnvironment.executeSql(
   "CREATE TABLE tablesource (\n" +
      "    name string,\n" +
     "     age int,\n" +
     "     sex string,\n" +
      "    dt string,\n" +
     "     ptime as PROCTIME()\n" +
      ") WITH (\n" +
      "    'connector' = 'kafka',\n" +
      "    'topic' = 'xxxx',\n" +
      "    'scan.startup.mode' = 'group-offsets',\n" +
      "    'properties.bootstrap.servers' = 'xxxx',\n" +
      "    'properties.group.id' = 'xxx',\n" +
      "    'format' = 'csv',\n" +
      "    'csv.field-delimiter' = ','\n" +
      ")");



    tableEnvironment.executeSql(
      "CREATE TABLE tablesink1 (\n" +
        "     name string,\n" +
        "     age int,\n" +
        "     sex string,\n" +
        "     dt string,\n" +
        "     ptime TIMESTAMP(3)\n" +
        ") WITH (\n" +
        "    'connector' = 'kafka',\n" +
        "    'topic' = 'xxxx',\n" +
        "    'properties.bootstrap.servers' = 'xxx',\n" +
        "    'properties.group.id' = 'xxxx',\n" +
        "    'format' = 'csv',\n" +
        "    'csv.field-delimiter' = ','\n" +
        ")");



    tableEnvironment.executeSql(
    "CREATE TABLE tablesink2 (\n" +
      "    name STRING,\n" +
      "    age INTEGER,\n" +
      "    sex STRING,\n" +
      "    dtime STRING,\n" +
      "    ptime TIMESTAMP(3),\n" +                  -- there is a error for 
extra comma.
      ") WITH (\n" +
      "    'connector.type' = 'print'\n" +
      ")");

    

      StatementSet s = tableEnvironment.createStatementSet();
      s.addInsertSql("insert into tablesink1 select * from jdqtablesource");
      s.addInsertSql("insert into tablesink2 select * from jmqtable");
      s.explain();
      s.execute();


{code}

> Print  sql when parse failed  , which is convenient to find error sql from  
> multiple executed sql 
> --------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-23810
>                 URL: https://issues.apache.org/jira/browse/FLINK-23810
>             Project: Flink
>          Issue Type: Improvement
>          Components: Table SQL / API
>            Reporter: hehuiyuan
>            Priority: Major
>
> Print sql when parse failed , which is convenient to find error sql.
>  
> {code:java}
> public SqlNode parse(String sql) {
>     try {
>         SqlParser parser = SqlParser.create(sql, config);
>         return parser.parseStmt();
>     } catch (SqlParseException e) {
>         throw new SqlParserException("SQL parse failed. " + e.getMessage(), 
> e);
>     }
> }
> {code}
>  
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)