基於監聽hdfs文件實現Sparkstreaming優雅關閉

前提：java            Yarn的Kill和發送信號，Oozie，不是優雅關閉，CDH的關閉是優雅關閉，如今打算棄用CDH，因此基於代碼實現監聽外部文件系統實現優雅關閉。app 1、oop 1.實現代碼spa val hdfsStopPath :String = args(1) var stopFlag = false while (!stopFlag) {

>>阅读原文<<