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
index f4c638381..3c1be25c6 100644
--- 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);
                 }
             }