java - sparkstreming不通过checkpoint怎么进行driver恢复,怎么解决???
ringa_lee
ringa_lee 2017-04-18 10:52:48
0
0
548

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

ringa_lee
ringa_lee

ringa_lee

모든 응답(0)
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿