File tree Expand file tree Collapse file tree 1 file changed +8
-5
lines changed
core/src/main/java/com/dtstack/flink/sql/parser Expand file tree Collapse file tree 1 file changed +8
-5
lines changed Original file line number Diff line number Diff line change @@ -138,12 +138,15 @@ public static SqlTree parseSql(String sql) throws Exception {
138138 if (!sqlTree .getTableInfoMap ().keySet ().contains (tableName )){
139139 CreateTableParser .SqlParserResult createTableResult = sqlTree .getPreDealTableMap ().get (tableName );
140140 if (createTableResult == null ){
141- throw new RuntimeException ("can't find table " + tableName );
141+ CreateTmpTableParser .SqlParserResult tmpTableResult = sqlTree .getTmpTableMap ().get (tableName );
142+ if (tmpTableResult == null ){
143+ throw new RuntimeException ("can't find table " + tableName );
144+ }
145+ } else {
146+ TableInfo tableInfo = tableInfoParser .parseWithTableType (ETableType .SOURCE .getType (),
147+ createTableResult , LOCAL_SQL_PLUGIN_ROOT );
148+ sqlTree .addTableInfo (tableName , tableInfo );
142149 }
143-
144- TableInfo tableInfo = tableInfoParser .parseWithTableType (ETableType .SOURCE .getType (),
145- createTableResult , LOCAL_SQL_PLUGIN_ROOT );
146- sqlTree .addTableInfo (tableName , tableInfo );
147150 }
148151 }
149152 }
You can’t perform that action at this time.
0 commit comments