diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-12-18 23:39:28 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-12-18 23:39:28 -0800 |
| commit | ec71b445ad0440e84c4b4909e4faf75aba0f13d7 (patch) | |
| tree | 3594700c37b6baf2c4297ad7819e4a223f835bfc /streaming/src/test | |
| parent | e93b391d75a1c2e17ad93caff39e8fc34d640935 (diff) | |
| download | spark-ec71b445ad0440e84c4b4909e4faf75aba0f13d7.tar.gz spark-ec71b445ad0440e84c4b4909e4faf75aba0f13d7.tar.bz2 spark-ec71b445ad0440e84c4b4909e4faf75aba0f13d7.zip | |
Minor changes.
Diffstat (limited to 'streaming/src/test')
| -rw-r--r-- | streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala index 826c839932..16410a21e3 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala @@ -34,7 +34,7 @@ class StreamingListenerSuite extends TestSuiteBase with ShouldMatchers{ test("basic BatchInfo generation") { val ssc = setupStreams(input, operation) val collector = new BatchInfoCollector - ssc.addListener(collector) + ssc.addStreamingListener(collector) runStreams(ssc, input.size, input.size) val batchInfos = collector.batchInfos batchInfos should have size 4 |