解决同时使用all和async维表的BUG【http://redmine.prod.dtstack.cn/issues/21893?issue_count=4&issue_position=4&prev_issue_id=22739】

dapeng · dapeng · commit 6bdc1f29fd7b · 2020-03-11T09:16:43.000+08:00
diff --git a/core/src/main/java/com/dtstack/flink/sql/table/TableInfoParser.java b/core/src/main/java/com/dtstack/flink/sql/table/TableInfoParser.java
@@ -76,11 +76,11 @@ public TableInfo parseWithTableType(int tableType, CreateTableParser.SqlParserRe
                     sourceTableInfoMap.put(type, absTableParser);
                 }
             }else{
-                absTableParser = sideTableInfoMap.get(type);
+                String cacheType = MathUtil.getString(props.get(SideTableInfo.CACHE_KEY));
+                absTableParser = sideTableInfoMap.get(type + cacheType);
                 if(absTableParser == null){
-                    String cacheType = MathUtil.getString(props.get(SideTableInfo.CACHE_KEY));
                     absTableParser = StreamSideFactory.getSqlParser(type, localPluginRoot, cacheType);
-                    sideTableInfoMap.put(type, absTableParser);
+                    sideTableInfoMap.put(type + cacheType, absTableParser);
                 }
             }
 

Original file line number	Diff line number	Diff line change
`@@ -76,11 +76,11 @@ public TableInfo parseWithTableType(int tableType, CreateTableParser.SqlParserRe`
`76`	`76`	`sourceTableInfoMap.put(type, absTableParser);`
`77`	`77`	`}`
`78`	`78`	`}else{`
`79`		`- absTableParser = sideTableInfoMap.get(type);`
	`79`	`+ String cacheType = MathUtil.getString(props.get(SideTableInfo.CACHE_KEY));`
	`80`	`+ absTableParser = sideTableInfoMap.get(type + cacheType);`
`80`	`81`	`if(absTableParser == null){`
`81`		`- String cacheType = MathUtil.getString(props.get(SideTableInfo.CACHE_KEY));`
`82`	`82`	`absTableParser = StreamSideFactory.getSqlParser(type, localPluginRoot, cacheType);`
`83`		`- sideTableInfoMap.put(type, absTableParser);`
	`83`	`+ sideTableInfoMap.put(type + cacheType, absTableParser);`
`84`	`84`	`}`
`85`	`85`	`}`
`86`	`86`