兼容primaryKey

dapeng · dapeng · commit 27c0f8b4428c · 2020-07-13T11:36:19.000+08:00
diff --git a/redis5/redis5-sink/src/main/java/com/dtstack/flink/sql/sink/redis/table/RedisSinkParser.java b/redis5/redis5-sink/src/main/java/com/dtstack/flink/sql/sink/redis/table/RedisSinkParser.java
@@ -50,11 +50,11 @@ public AbstractTableInfo getTableInfo(String tableName, String fieldsInfo, Map<S
         redisTableInfo.setMasterName(MathUtil.getString(props.get(RedisTableInfo.MASTER_NAME.toLowerCase())));
 
         String primaryKeysStr = MathUtil.getString(props.get(RedisTableInfo.PRIMARY_KEYS_NAME));
-        List<String> primaryKeysList = Lists.newArrayList();
         if (!StringUtils.isEmpty(primaryKeysStr)) {
+            List<String> primaryKeysList = Lists.newArrayList();
             primaryKeysList = Arrays.asList(StringUtils.split(primaryKeysStr, ","));
+            redisTableInfo.setPrimaryKeys(primaryKeysList);
         }
-        redisTableInfo.setPrimaryKeys(primaryKeysList);
 
         return redisTableInfo;
     }

Original file line number	Diff line number	Diff line change
`@@ -50,11 +50,11 @@ public AbstractTableInfo getTableInfo(String tableName, String fieldsInfo, Map<S`
`50`	`50`	`redisTableInfo.setMasterName(MathUtil.getString(props.get(RedisTableInfo.MASTER_NAME.toLowerCase())));`
`51`	`51`
`52`	`52`	`String primaryKeysStr = MathUtil.getString(props.get(RedisTableInfo.PRIMARY_KEYS_NAME));`
`53`		`- List<String> primaryKeysList = Lists.newArrayList();`
`54`	`53`	`if (!StringUtils.isEmpty(primaryKeysStr)) {`
	`54`	`+ List<String> primaryKeysList = Lists.newArrayList();`
`55`	`55`	`primaryKeysList = Arrays.asList(StringUtils.split(primaryKeysStr, ","));`
	`56`	`+ redisTableInfo.setPrimaryKeys(primaryKeysList);`
`56`	`57`	`}`
`57`		`- redisTableInfo.setPrimaryKeys(primaryKeysList);`
`58`	`58`
`59`	`59`	`return redisTableInfo;`
`60`	`60`	`}`