We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1f467e8 commit 715bce3Copy full SHA for 715bce3
core/src/main/java/com/dtstack/flink/sql/side/SideSqlExec.java
@@ -114,7 +114,7 @@ public void exec(String sql,
114
115
SideSQLParser sideSQLParser = new SideSQLParser();
116
sideSQLParser.setLocalTableCache(localTableCache);
117
- Queue<Object> exeQueue = sideSQLParser.getExeQueue(sql, sideTableMap.keySet());
+ Queue<Object> exeQueue = sideSQLParser.getExeQueue(sql, sideTableMap.keySet(), scope);
118
Object pollObj;
119
120
//need clean
0 commit comments