flink1.8??????????lettuce

[wujunxi]

flinkIOredislettuce??
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 

??????Flink??SavePoint??????????????????????????

[wujunxi]

1.id
2.savepoint??



----
??:"milan183sansiro"

flink table??????????????????????????????

[wujunxi]

flink??1.8.0
??flink table
??
tEnv.registerDataStream("t_data",dataStream,"f1-1");
??
org.apache.flink.table.api.TableException: 
Field reference expression expected.