From 700dfb4957dae32625cf6af2da5482775677c049 Mon Sep 17 00:00:00 2001 From: Varun Sharma Date: Thu, 6 Nov 2014 23:13:39 +0530 Subject: [PATCH] SPARK-4276 fix for two working thread --- .../apache/spark/examples/streaming/NetworkWordCount.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/NetworkWordCount.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/NetworkWordCount.scala index ae0a08c6cdb1a..f9d13c477067e 100644 --- a/examples/src/main/scala/org/apache/spark/examples/streaming/NetworkWordCount.scala +++ b/examples/src/main/scala/org/apache/spark/examples/streaming/NetworkWordCount.scala @@ -42,8 +42,8 @@ object NetworkWordCount { StreamingExamples.setStreamingLogLevels() - // Create the context with a 1 second batch size - val sparkConf = new SparkConf().setAppName("NetworkWordCount") + // Create a local StreamingContext with two working thread and batch interval of 1 second + val sparkConf = new SparkConf().setMaster("local[2]").setAppName("NetworkWordCount") val ssc = new StreamingContext(sparkConf, Seconds(1)) // Create a socket stream on target ip:port and count the