diff options
author | Yanbo Liang <ybliang8@gmail.com> | 2015-09-18 09:53:52 -0700 |
---|---|---|
committer | Xiangrui Meng <meng@databricks.com> | 2015-09-18 09:53:52 -0700 |
commit | 35e8ab939000d4a1a01c1af4015c25ff6f4013a3 (patch) | |
tree | af13816f2009349515257d5b6a2c38b39e1bb6a8 /python/pyspark/streaming | |
parent | 20fd35dfd1ac402b622604e7bbedcc53a580b0a2 (diff) | |
download | spark-35e8ab939000d4a1a01c1af4015c25ff6f4013a3.tar.gz spark-35e8ab939000d4a1a01c1af4015c25ff6f4013a3.tar.bz2 spark-35e8ab939000d4a1a01c1af4015c25ff6f4013a3.zip |
[SPARK-10615] [PYSPARK] change assertEquals to assertEqual
As ```assertEquals``` is deprecated, so we need to change ```assertEquals``` to ```assertEqual``` for existing python unit tests.
Author: Yanbo Liang <ybliang8@gmail.com>
Closes #8814 from yanboliang/spark-10615.
Diffstat (limited to 'python/pyspark/streaming')
-rw-r--r-- | python/pyspark/streaming/tests.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/streaming/tests.py b/python/pyspark/streaming/tests.py index cfea95b0de..e4e56fff3b 100644 --- a/python/pyspark/streaming/tests.py +++ b/python/pyspark/streaming/tests.py @@ -693,7 +693,7 @@ class CheckpointTests(unittest.TestCase): # Verify that getActiveOrCreate() returns active context self.setupCalled = False - self.assertEquals(StreamingContext.getActiveOrCreate(self.cpd, setup), self.ssc) + self.assertEqual(StreamingContext.getActiveOrCreate(self.cpd, setup), self.ssc) self.assertFalse(self.setupCalled) # Verify that getActiveOrCreate() uses existing SparkContext |