Skip to content

Commit 88b7da2

Browse files
author
yanxi0227
committed
add password
1 parent f8d6923 commit 88b7da2

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

redis5/redis5-sink/src/main/java/com/dtstack/flink/sql/sink/redis/RedisOutputFormat.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ private void establishConnection() {
126126
break;
127127
//集群
128128
case 3:
129-
jedis = new JedisCluster(addresses, timeout, timeout,1, poolConfig);
129+
jedis = new JedisCluster(addresses, timeout, timeout,10, password, poolConfig);
130130
}
131131
}
132132

0 commit comments

Comments
 (0)