Merge branch 'hotfix_1.8_3.9.x_21893' into 1.8_release_3.10.x

gituser · gituser · commit 6159bb9bb990 · 2020-03-19T15:09:58.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
@@ -77,11 +77,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
`@@ -77,11 +77,11 @@ public TableInfo parseWithTableType(int tableType, CreateTableParser.SqlParserRe`
`77`	`77`	`sourceTableInfoMap.put(type, absTableParser);`
`78`	`78`	`}`
`79`	`79`	`}else{`
`80`		`- absTableParser = sideTableInfoMap.get(type);`
	`80`	`+ String cacheType = MathUtil.getString(props.get(SideTableInfo.CACHE_KEY));`
	`81`	`+ absTableParser = sideTableInfoMap.get(type + cacheType);`
`81`	`82`	`if(absTableParser == null){`
`82`		`- String cacheType = MathUtil.getString(props.get(SideTableInfo.CACHE_KEY));`
`83`	`83`	`absTableParser = StreamSideFactory.getSqlParser(type, localPluginRoot, cacheType);`
`84`		`- sideTableInfoMap.put(type, absTableParser);`
	`84`	`+ sideTableInfoMap.put(type + cacheType, absTableParser);`
`85`	`85`	`}`
`86`	`86`	`}`
`87`	`87`