pengdaolong

Results 2 issues of pengdaolong

2.1 Flink Checkpoint-轻量级分布式快照 找不到视频

mycode : ``` object SparkToRedisDemo { def main(args: Array[String]): Unit = { val sparkSession = SparkSession.builder() .config("redis.host", "192.168.1.244") .config("redis.port", "6379") .appName("spark-redis") .getOrCreate() val sc = sparkSession.sparkContext val datas = sparkSession.read.textFile("hdfs://hadoop1:8020/testData/input/*")...