Skip to content

Commit 437d900

Browse files
dujietiezhu
authored andcommitted
[hotfix-6279][redis] resolve zset's score type convent error
1 parent db59f23 commit 437d900

File tree

1 file changed

+7
-6
lines changed

1 file changed

+7
-6
lines changed

flinkx-connectors/flinkx-connector-redis/src/main/java/com/dtstack/flinkx/connector/redis/converter/RedisColumnConverter.java

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -67,12 +67,13 @@ public RedisColumnConverter(RedisConf redisConf) {
6767
&& CollectionUtils.isNotEmpty(redisConf.getColumn())) {
6868
fieldIndex = new ArrayList<>(redisConf.getColumn().size());
6969
for (int i = 0; i < redisConf.getColumn().size(); i++) {
70-
fieldIndex.add(i);
71-
}
72-
if (!redisConf.isIndexFillHash()
73-
&& CollectionUtils.isNotEmpty(redisConf.getKeyIndexes())) {
74-
for (int index : redisConf.getKeyIndexes()) {
75-
fieldIndex.remove(index);
70+
if (!redisConf.isIndexFillHash()
71+
&& CollectionUtils.isNotEmpty(redisConf.getKeyIndexes())) {
72+
if (!redisConf.getKeyIndexes().contains(i)) {
73+
fieldIndex.add(i);
74+
}
75+
} else {
76+
fieldIndex.add(i);
7677
}
7778
}
7879
}

0 commit comments

Comments
 (0)