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

gituser · gituser · commit 82e182d924da · 2020-03-19T15:08:39.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`