From 2f333c8aa9a4fb49fb2690520dce71a846c01c99 Mon Sep 17 00:00:00 2001 From: "sky.huang" Date: Wed, 14 Jun 2023 11:48:27 +0800 Subject: [PATCH] =?UTF-8?q?Fixes=20=E5=93=A8=E5=85=B5=E6=A8=A1=E5=BC=8F?= =?UTF-8?q?=E6=9C=AA=E8=AE=BE=E7=BD=AE=E7=AB=AF=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/java3y/austin/stream/utils/LettuceRedisUtils.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/austin-stream/src/main/java/com/java3y/austin/stream/utils/LettuceRedisUtils.java b/austin-stream/src/main/java/com/java3y/austin/stream/utils/LettuceRedisUtils.java index 7c9269a..bed24bc 100644 --- a/austin-stream/src/main/java/com/java3y/austin/stream/utils/LettuceRedisUtils.java +++ b/austin-stream/src/main/java/com/java3y/austin/stream/utils/LettuceRedisUtils.java @@ -29,12 +29,12 @@ public class LettuceRedisUtils { static { RedisURI redisUri = null; if (StrUtil.equals(AustinFlinkConstant.REDIS_MODE_SENTINEL, AustinFlinkConstant.REDIS_MODE)) { - redisUri = RedisURI.Builder.sentinel(AustinFlinkConstant.REDIS_IP, AustinFlinkConstant.MASTER_ID) + redisUri = RedisURI.Builder.sentinel(AustinFlinkConstant.REDIS_IP, AustinFlinkConstant.REDIS_PORT, AustinFlinkConstant.MASTER_ID) .withPassword(AustinFlinkConstant.REDIS_PASSWORD.toCharArray()) .build(); } else if (StrUtil.equals(AustinFlinkConstant.REDIS_MODE_SINGLE, AustinFlinkConstant.REDIS_MODE)) { redisUri = RedisURI.Builder.redis(AustinFlinkConstant.REDIS_IP) - .withPort(Integer.valueOf(AustinFlinkConstant.REDIS_PORT)) + .withPort(AustinFlinkConstant.REDIS_PORT) .withPassword(AustinFlinkConstant.REDIS_PASSWORD.toCharArray()) .build(); }