bugfix

dapeng · dapeng · commit af338b7acdf1 · 2020-03-11T13:51:39.000+08:00
diff --git a/redis5/redis5-side/redis-async-side/src/main/java/com/dtstack/flink/sql/side/redis/RedisAsyncReqRow.java b/redis5/redis5-side/redis-async-side/src/main/java/com/dtstack/flink/sql/side/redis/RedisAsyncReqRow.java
@@ -179,10 +179,10 @@ private String buildCacheKey(Map<String, Object> refData) {
         StringBuilder keyBuilder = new StringBuilder(redisSideTableInfo.getTableName());
         List<String> primaryKeys = redisSideTableInfo.getPrimaryKeys();
         for(String primaryKey : primaryKeys){
-            if(refData.containsKey(primaryKey)){
-                keyBuilder.append("_").append(refData.get(primaryKey));
+            if(!refData.containsKey(primaryKey)){
+                return null;
             }
-            return null;
+            keyBuilder.append("_").append(refData.get(primaryKey));
         }
         return keyBuilder.toString();
     }

Original file line number	Diff line number	Diff line change
`@@ -179,10 +179,10 @@ private String buildCacheKey(Map<String, Object> refData) {`
`179`	`179`	`StringBuilder keyBuilder = new StringBuilder(redisSideTableInfo.getTableName());`
`180`	`180`	`List<String> primaryKeys = redisSideTableInfo.getPrimaryKeys();`
`181`	`181`	`for(String primaryKey : primaryKeys){`
`182`		`- if(refData.containsKey(primaryKey)){`
`183`		`- keyBuilder.append("_").append(refData.get(primaryKey));`
	`182`	`+ if(!refData.containsKey(primaryKey)){`
	`183`	`+ return null;`
`184`	`184`	`}`
`185`		`- return null;`
	`185`	`+ keyBuilder.append("_").append(refData.get(primaryKey));`
`186`	`186`	`}`
`187`	`187`	`return keyBuilder.toString();`
`188`	`188`	`}`