sparkstreming不通过checkpoint怎么进行driver恢复，怎么解决？？？

sparkstreming读取kafka数据,不采用checkpoint来维护偏移量,自己通过zookeeper来维护,这里有一个问题如果sparkstreming的driver宕机,没有checkpoint怎么保证driver级别的...

ios android node.js html5 linux c++ css3 git golang ruby vim docker mongodb标签管理 问 sparkstreming不通过checkpoint怎么进行driver恢复,怎么解决??? java...

2016年5月24日 - 【SparkStreming】DStream中RDD所对应的周期是怎样的...但是文档上并没有提及每个RDD对应的时间周期是多少。...Spark的几个基本概念:Driver和Job,Stage(5271)如何...

2013年5月12日 - 第92讲 SparkStreming中的Transformations和状态管理 ...UpdaeStateByKey的操作,允许你维护任意的不断通过新...driver process running the streaming...

2017年3月18日 - SparkStreming向kafka写数据,报 Error in I/O... kafka sparkstreaming 我按照kafka官网部署了单节点kafka0.8.2.1,部署命令依次如下: //启动自带的zoo...

2015年8月15日 - [云计算]sparkstremingupdateStateByKey用法...2) 定义状态更新函数:用一个函数指定如何使用先前的...initialRDD) //set the checkpoint interval to ...

2016年5月10日 - 也就是结果RDD,如果RDD没有数据,就不需要进行操作,foreachRDD()可以将数据写在Redis/Hbase/数据库/具体文件中,foreachRDD是在Driver程序中执行的,func...

2016年5月10日 - UpdaeStateByKey的操作,允许你维护任意的不断通过新...driver process running the streaming application, ...【SparkStreming】DStream中RDD所对应...