我正在构建一个基于Apache Spark的应用程序,该应用程序可作用于多个流。
我已阅读文档中的性能调优部分:http://spark.apache.org/docs/latest/streaming-programming-guide.html#performance-tuning。
但我仍有以下疑问:
1)数据流接收器是否位于多个工作节点或驱动程序机器上?
2)如果接收数据的节点之一失败(断电/重新启动),会发生什么?
我已阅读文档中的性能调优部分:http://spark.apache.org/docs/latest/streaming-programming-guide.html#performance-tuning。
但我仍有以下疑问:
1)数据流接收器是否位于多个工作节点或驱动程序机器上?
2)如果接收数据的节点之一失败(断电/重新启动),会发生什么?