spark-reviews mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tdas <>
Subject [GitHub] spark pull request: [SPARK-6752][STREAMING][Revised] Allow Streami...
Date Tue, 12 May 2015 20:52:22 GMT
GitHub user tdas opened a pull request:

    [SPARK-6752][STREAMING][Revised] Allow StreamingContext to be recreated from checkpoint
and existing SparkContext

    This is a revision of the earlier version (see #5773) that passed the active SparkContext
explicitly through a new set of Java and Scala API. The drawbacks are.
    * Hard to implement in python. 
    * New API introduced. This is even more confusing since we are introducing getActiveOrCreate
in SPARK-7553
    Furthermore, there is now a direct way get an existing active SparkContext or create a
new on - SparkContext.getOrCreate(conf). Its better to use this to get the SparkContext rather
than have a new API to explicitly pass the context.
    So in this PR I have
    * Removed the new versions of StreamingContext.getOrCreate() which took SparkContext
    * Added the ability to pick up existing SparkContext when the StreamingContext tries to
create a SparkContext.

You can merge this pull request into a Git repository by running:

    $ git pull SPARK-6752

Alternatively you can review and apply these changes as the patch at:

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #6096
commit f024b77b16bf9b1996b31b0bc52e96f53565c06a
Author: Tathagata Das <>
Date:   2015-05-12T20:48:18Z

    Removed extra API and used SparkContext.getOrCreate


If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at or file a JIRA ticket
with INFRA.

To unsubscribe, e-mail:
For additional commands, e-mail:

View raw message