????flink????IO????redis????????lettuce?????????????????????????? Caused by: io.lettuce.core.RedisException: Cannot retrieve initial cluster partitions from initial URIs [RedisURI [host='XXX', port=XXX]] at io.lettuce.core.cluster.RedisClusterClient.loadPartitions(RedisClusterClient.java:808) at io.lettuce.core.cluster.RedisClusterClient.initializePartitions(RedisClusterClient.java:761) at io.lettuce.core.cluster.RedisClusterClient.connectClusterImpl(RedisClusterClient.java:500) at io.lettuce.core.cluster.RedisClusterClient.connect(RedisClusterClient.java:339) at io.lettuce.core.cluster.RedisClusterClient.connect(RedisClusterClient.java:316) at com.sangfor.abdi.AsyncRedis$2.open(AsyncRedis.java:67) at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36) at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102) at org.apache.flink.streaming.api.operators.async.AsyncWaitOperator.open(AsyncWaitOperator.java:163) at org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:424) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:290) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711) at java.lang.Thread.run(Thread.java:748)
??????????????flink1.10???????????????????????? ????????????????????????
