基于监听hdfs文件实现Sparkstreaming优雅关闭

前提：java            Yarn的Kill和发送信号，Oozie，不是优雅关闭，CDH的关闭是优雅关闭，如今打算弃用CDH，因此基于代码实现监听外部文件系统实现优雅关闭。app 1、oop 1.实现代码spa val hdfsStopPath :String = args(1) var stopFlag = false while (!stopFlag) {

>>阅读原文<<