diff options
| author | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2013-01-21 23:31:00 -0800 |
|---|---|---|
| committer | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2013-01-21 23:31:00 -0800 |
| commit | 551a47a620c7dc207e3530e54d794a3c3aa8e45e (patch) | |
| tree | 6348d4c24cce6da6f698c665a90784a8f3247fea /streaming/src | |
| parent | 7d3e359f2c463681cf0128da2c6692beb13dade9 (diff) | |
| download | spark-551a47a620c7dc207e3530e54d794a3c3aa8e45e.tar.gz spark-551a47a620c7dc207e3530e54d794a3c3aa8e45e.tar.bz2 spark-551a47a620c7dc207e3530e54d794a3c3aa8e45e.zip | |
Refactor daemon thread pool creation.
Diffstat (limited to 'streaming/src')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/dstream/RawInputDStream.scala | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/streaming/src/main/scala/spark/streaming/dstream/RawInputDStream.scala b/streaming/src/main/scala/spark/streaming/dstream/RawInputDStream.scala index 290fab1ce0..04e6b69b7b 100644 --- a/streaming/src/main/scala/spark/streaming/dstream/RawInputDStream.scala +++ b/streaming/src/main/scala/spark/streaming/dstream/RawInputDStream.scala @@ -1,6 +1,6 @@ package spark.streaming.dstream -import spark.{DaemonThread, Logging} +import spark.Logging import spark.storage.StorageLevel import spark.streaming.StreamingContext @@ -48,7 +48,8 @@ class RawNetworkReceiver(host: String, port: Int, storageLevel: StorageLevel) val queue = new ArrayBlockingQueue[ByteBuffer](2) - blockPushingThread = new DaemonThread { + blockPushingThread = new Thread { + setDaemon(true) override def run() { var nextBlockNumber = 0 while (true) { |