我记得官方文档明确说明这一点了的啊

至少要两个线程的
"local[2]"
instead of

"local"

非常感谢,支持

按照这种方式试一下

val wordCounts = words.map(x => (x, 1)).reduceByKeyAndWindow(_ + _, _ - _, Seconds(10s)，seconds(2))
复制代码

http://sluse.com/view/17362233  我勒个去，搜遍网络，只有这篇文章提到了解决方法



Just for the record: I got an answer in the Spark usergroup.
The error is that one has to use

"local[2]"
instead of

"local"
as a parameter to instantiate the Spark context, in order to enable concurrent processing.