You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 03:23:51 UTC
[rocketmq-connect] 07/08: Fix exception parsing redis command "set a 1010 px 1000" (#862)
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit 4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02
Author: yuz10 <84...@qq.com>
AuthorDate: Mon Feb 14 17:51:39 2022 +0800
Fix exception parsing redis command "set a 1010 px 1000" (#862)
---
src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java b/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
index 4165cc2..c0afe71 100644
--- a/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
+++ b/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
@@ -41,7 +41,7 @@ public class SetParser extends AbstractCommandParser {
builder.value(args[0]);
int idx = 1;
while (idx < args.length){
- String param = toRune(args[idx++]);
+ String param = args[idx++];
if (isEquals(param, RedisConstants.NX)) {
builder.param(Options.REDIS_NX, Boolean.TRUE);
} else if (isEquals(param, RedisConstants.XX)) {