Skip to content

Commit 09a8d23

Browse files
author
gituser
committed
Merge branch 'hotfix_1.8_3.10.x_29012' into 1.8_release_3.10.x
2 parents e73b8ff + 6b28712 commit 09a8d23

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)