locally 的 spark streaming 任务如何停止？
spark 部署方式分 locally，standalone，mesos，yarn standalone，mesos 可以用 spark-submit --master $MASTER_REST_URL --kill $DRIVER_ID 来停止 …
spark streaming 集成 kafka，使用window时出现错误
当使用 spark streaming 2.0.0 集成 kafka 0.10.0时出现 KafkaConsumer 多线程争用的问题。部分代码如下： val ssc = new StreamingContext(sc, Seco…
本地 Spark 连不上 web－ui ，请大神指教
想在 web ui 里看看自己spark任务的状况，但是在本地执行了任务，在web ui里却什么都没有显示。请问是需要什么特殊指令吗？ conf = SparkConf().setM…
SparkStream接受Kafka数据，数据处理时发生任务堵塞，如何处理?
SparkStream运行30分钟后就出现了任务堵塞，现在的任务一直在卡(没有报错)，后面的任务一直在排队。Spark on yarn 内存都足够。 读取Kafka数据成List…
Spark Streaming集成Kafka代码构建失败
env ubuntu14.04 64bit java 1.8 scala 2.11.7 spark-hadoop2.6 1.5.1 interlliJ IDEA sbt 0.13 问题 自己照着Spark streaming example修改了一点代…
