reset catalog in pyspark tests

apache · Mar 14, 2017 · 739f207 · 739f207
1 parent cd4a091
commit 739f207
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/python/pyspark/sql/tests.py b/python/pyspark/sql/tests.py
@@ -197,6 +197,8 @@ def setUpClass(cls):
         cls.tempdir = tempfile.NamedTemporaryFile(delete=False)
         os.unlink(cls.tempdir.name)
         cls.spark = SparkSession(cls.sc)
+        cls.spark.catalog._reset()
+
         cls.testData = [Row(key=i, value=str(i)) for i in range(100)]
         cls.df = cls.spark.createDataFrame(cls.testData)