1

我使用最新的 Spark 1.6.0。

看了另一个 stackoverflow 帖子How can I make Spark Streaming count the words in a file in a unit test?

我正在尝试使用示例 @ https://gist.github.com/emres/67b4eae86fa92df69f61 来编写 Spark 的示例单元测试。之后我打算为我的实际 Spark 应用程序编写一个单元测试。但是，我无法使用示例 @ https://gist.github.com/emres/67b4eae86fa92df69f61。这给了我错误

java.lang.IllegalStateException：oracle.security.ti.reportgenerator.test.StarterAppTest.testCountWords(StarterAppTest.java:62) 不支持在启动上下文后添加新的输入、转换和输出操作

有什么想法可以解决这个问题吗？

4

1 回答 1

2

开始流式传输 context后，您无法在JavaPairDStream wordCounts上执行wordCounts.print()。

于 2016-02-12T23:34:02.223 回答