---tableName---user_log
---planner---flink
---ETableType.SOURCE.getType()---1
---createTableResult---com.dtstack.flink.sql.parser.CreateTableParser$SqlParserResult@183c5a5
---LOCAL_SQL_PLUGIN_ROOT---null
---pluginLoadMode---LocalTest
---LOCAL_SQL_PLUGIN_ROOT---null
Exception in thread "main" java.lang.RuntimeException: create table statement requires property of type
at com.dtstack.flink.sql.table.AbstractTableInfoParser.parseWithTableType(AbstractTableInfoParser.java:90)
at com.dtstack.flink.sql.parser.SqlParser.parseSql(SqlParser.java:132)
at com.dtstack.flink.sql.exec.ExecuteProcessHelper.getStreamExecution(ExecuteProcessHelper.java:201)
at com.dtstack.flink.sql.Main.main(Main.java:45)
at com.dtstack.flink.sql.localTest.LocalTest.main(LocalTest.java:84)
---tableName---user_log ---planner---flink ---ETableType.SOURCE.getType()---1 ---createTableResult---com.dtstack.flink.sql.parser.CreateTableParser$SqlParserResult@183c5a5 ---LOCAL_SQL_PLUGIN_ROOT---null ---pluginLoadMode---LocalTest ---LOCAL_SQL_PLUGIN_ROOT---null Exception in thread "main" java.lang.RuntimeException: create table statement requires property of type at com.dtstack.flink.sql.table.AbstractTableInfoParser.parseWithTableType(AbstractTableInfoParser.java:90) at com.dtstack.flink.sql.parser.SqlParser.parseSql(SqlParser.java:132) at com.dtstack.flink.sql.exec.ExecuteProcessHelper.getStreamExecution(ExecuteProcessHelper.java:201) at com.dtstack.flink.sql.Main.main(Main.java:45) at com.dtstack.flink.sql.localTest.LocalTest.main(LocalTest.java:84)
Process finished with exit code 1