Skip to content

Commit 59dcaf8

Browse files
committed
fix mongo sync read bug
1 parent 4aaa7a4 commit 59dcaf8

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

mongo/mongo-side/mongo-async-side/src/main/java/com/dtstack/flink/sql/side/mongo/MongoAsyncReqRow.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -142,12 +142,12 @@ public void asyncInvoke(Row input, ResultFuture<Row> resultFuture) throws Except
142142
dealMissKey(input, resultFuture);
143143
return;
144144
} else if (ECacheContentType.MultiLine == val.getType()) {
145-
145+
List<Row> rowList = Lists.newArrayList();
146146
for (Object jsonArray : (List) val.getContent()) {
147147
Row row = fillData(input, jsonArray);
148-
resultFuture.complete(Collections.singleton(row));
148+
rowList.add(row);
149149
}
150-
150+
resultFuture.complete(rowList);
151151
} else {
152152
throw new RuntimeException("not support cache obj type " + val.getType());
153153
}

0 commit comments

Comments
 (0)