GitHub user tdas opened a pull request: https://github.com/apache/incubator-spark/pull/558
Refactored NetworkReceiver in Spark Streaming to allow for a You can merge this pull request into a Git repository by running: $ git pull https://github.com/apache/incubator-spark graceful-shutdown Alternatively you can review and apply these changes as the patch at: https://github.com/apache/incubator-spark/pull/558.patch ---- commit eab351d05c0baef1d4b549e1581310087158d78d Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-01-23T06:17:15Z Update Spark Streaming Programming Guide. commit 036a7d46187ea3f2a0fb8349ef78f10d6c0b43a9 Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-01-23T06:17:42Z Merge remote-tracking branch 'apache/master' into docs-update commit f06b964a51bb3b21cde2ff8bdea7d9785f6ce3a9 Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-01-23T06:49:12Z Fixed missing endhighlight tag in the MLlib guide. commit 6c29524639463f11eec721e4d17a9d7159f2944b Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-01-24T02:49:39Z Added example and figure for window operations, and links to Kafka and Flume API docs. commit e3dcb46ab83d7071f611d9b5008ba6bc16c9f951 Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-01-27T02:41:12Z Fixed docs on StreamingContext.getOrCreate. commit d5b6196b532b5746e019b959a79ea0cc013a8fc3 Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-01-27T04:15:58Z Added spark.streaming.unpersist config and info on StreamingListener interface. commit 89a81ff25726bf6d26163e0dd938290a79582c0f Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-01-27T21:08:34Z Updated docs based on Patricks PR comments. commit f338a60ae8069e0a382d2cb170227e5757cc0b7a Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-01-28T06:42:42Z More updates based on Patrick and Harvey's comments. commit 34a5a6008dac2e107624c7ff0db0824ee5bae45f Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-01-29T02:02:28Z Updated github url to use SPARK_GITHUB_URL variable. commit 18ff10556570b39d672beeb0a32075215cfcc944 Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-01-29T05:49:30Z Fixed a lot of broken links. commit 24165ff00a892809e10b5c39d4d86023260213bd Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-02-06T09:48:28Z Added graceful shutdown to Spark Streaming. commit 20f10c0bac64e2a95a1cf7b44a7f440be0897d9c Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-02-07T22:07:15Z Refactored NetworkReceiver to clearly define the public API and separate all the code to run a receiver into NetworkReceiverHandler. commit 177b12f8656aeeacf8125b86bb5c8baddf9b6650 Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-02-07T22:16:13Z Merge remote-tracking branch 'apache/master' into graceful-shutdown Conflicts: streaming/src/main/scala/org/apache/spark/streaming/receivers/ActorReceiver.scala commit 1b1cbfcddfa020fea3e6e0ff2a1fa7c1c82f6b8f Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-02-07T22:19:28Z Revert accidental change in slaves file. commit 281fead3a36836dc75083fe269062bd4b7014fd4 Author: Tathagata Das <tathagata.das1...@gmail.com> Date: 2014-02-07T22:29:56Z Minor changes before PR. ----