Skip to content

Commit a5a04ce

Browse files
committed
fix redis asyn read info bug
1 parent 59dcaf8 commit a5a04ce

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

redis5/redis5-side/redis-async-side/src/main/java/com/dtstack/flink/sql/side/redis/RedisAsyncReqRow.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -141,8 +141,12 @@ public void asyncInvoke(Row input, ResultFuture<Row> resultFuture) throws Except
141141
dealMissKey(input, resultFuture);
142142
return;
143143
}else if(ECacheContentType.MultiLine == val.getType()){
144-
Row row = fillData(input, val.getContent());
145-
resultFuture.complete(Collections.singleton(row));
144+
List<Row> rowList = Lists.newArrayList();
145+
for (Object jsonArray : (List) val.getContent()) {
146+
Row row = fillData(input, val.getContent());
147+
rowList.add(row);
148+
}
149+
resultFuture.complete(rowList);
146150
}else{
147151
throw new RuntimeException("not support cache obj type " + val.getType());
148152
}

0 commit comments

Comments
 (0)