我们应该做的是：

dstream.foreachRDD{rdd =>
    if (rdd.isEmpty) {
        streamingContext.stop()
    }
}

但是请注意，根据应用程序工作流的不同，第一批（或中间的某批）也可能是空的，因此您的作业将在第一次运行时停止。您可能需要结合一些条件以获得更可靠的停止。