想用spark读取sentinel的redis数据,我用了spark-redis的jar包,但这个包在SparkConf初始化的时候需要指定redis.host和redis.port,val sparkConf = new SparkConf().setAppName("Test").set("redis.host", "192.16.1.90").set("redis.port", "6379")但如果指定的那台机器挂了...
显示全部想用spark读取sentinel的redis数据,我用了spark-redis的jar包,但这个包在SparkConf初始化的时候需要指定redis.host和redis.port,
val sparkConf = new SparkConf().setAppName("Test").set("redis.host", "192.16.1.90").set("redis.port", "6379")
但如果指定的那台机器挂了,程序就停了,这个怎么解决?
收起