aboutsummaryrefslogtreecommitdiff
path: root/streaming
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2013-02-25 18:11:00 -0800
committerMatei Zaharia <matei@eecs.berkeley.edu>2013-02-25 18:11:00 -0800
commit7b8853493248f4b2855a548facc407a3db939ba0 (patch)
tree6b4074ac549f3633666725b1a8aeabd7c54066df /streaming
parentc45d6f1248de6dc1481ed021f43b8e81d301207e (diff)
parentbc4a6eb850c84793aa65c0dd2e27f379876b1969 (diff)
downloadspark-7b8853493248f4b2855a548facc407a3db939ba0.tar.gz
spark-7b8853493248f4b2855a548facc407a3db939ba0.tar.bz2
spark-7b8853493248f4b2855a548facc407a3db939ba0.zip
Merge pull request #502 from tdas/master
Very minor change in a testcase
Diffstat (limited to 'streaming')
-rw-r--r--streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala4
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);