diff options
| author | Saisai Shao <saisai.shao@intel.com> | 2015-02-23 11:27:27 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-02-23 11:27:27 +0000 |
| commit | 757b14b862a1d39c1bad7b321dae1a3ea8338fbb (patch) | |
| tree | 1efe1de1b8b5dd9a13b482d099f760ca4e532a09 /python/pyspark/streaming/context.py | |
| parent | 934876741683fc254fed18e7ff630614f78944be (diff) | |
| download | spark-757b14b862a1d39c1bad7b321dae1a3ea8338fbb.tar.gz spark-757b14b862a1d39c1bad7b321dae1a3ea8338fbb.tar.bz2 spark-757b14b862a1d39c1bad7b321dae1a3ea8338fbb.zip | |
[SPARK-5943][Streaming] Update the test to use new API to reduce the warning
Author: Saisai Shao <saisai.shao@intel.com>
Closes #4722 from jerryshao/SPARK-5943 and squashes the following commits:
1b01233 [Saisai Shao] Update the test to use new API to reduce the warning
Diffstat (limited to 'python/pyspark/streaming/context.py')
| -rw-r--r-- | python/pyspark/streaming/context.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/streaming/context.py b/python/pyspark/streaming/context.py index b06ab65037..2c73083c9f 100644 --- a/python/pyspark/streaming/context.py +++ b/python/pyspark/streaming/context.py @@ -189,7 +189,7 @@ class StreamingContext(object): if timeout is None: self._jssc.awaitTermination() else: - self._jssc.awaitTermination(int(timeout * 1000)) + self._jssc.awaitTerminationOrTimeout(int(timeout * 1000)) def awaitTerminationOrTimeout(self, timeout): """ |