Skip to content

Commit 3421969

Browse files
author
gituser
committed
Merge branch '1.8_release_3.10.x' into 1.8_release_4.0.x
2 parents 6d396e5 + 09a8d23 commit 3421969

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,7 @@ public void accept(Map<String, String> values) {
141141
if (MapUtils.isNotEmpty(values)) {
142142
try {
143143
Row row = fillData(input.row(), values);
144-
dealCacheData(key,CacheObj.buildCacheObj(ECacheContentType.MultiLine, values));
144+
dealCacheData(key,CacheObj.buildCacheObj(ECacheContentType.SingleLine, row));
145145
resultFuture.complete(Collections.singleton(new CRow(row, input.change())));
146146
} catch (Exception e) {
147147
dealFillDataError(input, resultFuture, e);

0 commit comments

Comments
 (0)