diff options
author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-02-25 18:11:00 -0800 |
---|---|---|
committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-02-25 18:11:00 -0800 |
commit | 7b8853493248f4b2855a548facc407a3db939ba0 (patch) | |
tree | 6b4074ac549f3633666725b1a8aeabd7c54066df | |
parent | c45d6f1248de6dc1481ed021f43b8e81d301207e (diff) | |
parent | bc4a6eb850c84793aa65c0dd2e27f379876b1969 (diff) | |
download | spark-7b8853493248f4b2855a548facc407a3db939ba0.tar.gz spark-7b8853493248f4b2855a548facc407a3db939ba0.tar.bz2 spark-7b8853493248f4b2855a548facc407a3db939ba0.zip |
Merge pull request #502 from tdas/master
Very minor change in a testcase
-rw-r--r-- | streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala b/streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala index 1024d3ac97..ebcb6d0092 100644 --- a/streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala +++ b/streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala @@ -94,7 +94,7 @@ class InputStreamsSuite extends TestSuiteBase with BeforeAndAfter { test("flume input stream") { // Set up the streaming context and input streams val ssc = new StreamingContext(master, framework, batchDuration) - val flumeStream = ssc.flumeStream("localhost", 33333, StorageLevel.MEMORY_AND_DISK) + val flumeStream = ssc.flumeStream("localhost", testPort, StorageLevel.MEMORY_AND_DISK) val outputBuffer = new ArrayBuffer[Seq[SparkFlumeEvent]] with SynchronizedBuffer[Seq[SparkFlumeEvent]] val outputStream = new TestOutputStream(flumeStream, outputBuffer) @@ -104,7 +104,7 @@ class InputStreamsSuite extends TestSuiteBase with BeforeAndAfter { val clock = ssc.scheduler.clock.asInstanceOf[ManualClock] val input = Seq(1, 2, 3, 4, 5) Thread.sleep(1000) - val transceiver = new NettyTransceiver(new InetSocketAddress("localhost", 33333)); + val transceiver = new NettyTransceiver(new InetSocketAddress("localhost", testPort)); val client = SpecificRequestor.getClient( classOf[AvroSourceProtocol], transceiver); |