aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/streaming/tests.py
diff options
context:
space:
mode:
authorYanbo Liang <ybliang8@gmail.com>2015-09-18 09:53:52 -0700
committerXiangrui Meng <meng@databricks.com>2015-09-18 09:53:52 -0700
commit35e8ab939000d4a1a01c1af4015c25ff6f4013a3 (patch)
treeaf13816f2009349515257d5b6a2c38b39e1bb6a8 /python/pyspark/streaming/tests.py
parent20fd35dfd1ac402b622604e7bbedcc53a580b0a2 (diff)
downloadspark-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/tests.py')
-rw-r--r--python/pyspark/streaming/tests.py2
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