flink1.8中无法使用lettuce

[KrisWu]

想用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可以使用，请问如何解决？   或者是否有其他客户端选择