GitHub user zsxwing opened a pull request:

    https://github.com/apache/spark/pull/23023

    [SPARK-26042][SS][TESTS]Fix a potential hang in 
KafkaContinuousSourceTopicDeletionSuite

    ## What changes were proposed in this pull request?
    
    As initializing lazy vals shares the same lock, a thread is trying to 
initialize `executedPlan` when `isRDD` is running, this thread will hang 
forever.
    
    This PR just materializes `executedPlan` so that accessing it when `toRdd` 
is running doesn't need to wait for a lock
    
    ## How was this patch tested?
    
    Jenkins

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

    $ git pull https://github.com/zsxwing/spark SPARK-26042

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

    https://github.com/apache/spark/pull/23023.patch

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

    This closes #23023
    
----
commit 33b51136e6292db8236c6d39d662887d18a9534d
Author: Shixiong Zhu <zsxwing@...>
Date:   2018-11-13T17:42:08Z

    Fix a potential hang in KafkaContinuousSourceTopicDeletionSuite

----


---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org

Reply via email to