diff --git a/python/pyspark/sql/tests/test_readwriter.py b/python/pyspark/sql/tests/test_readwriter.py index 921d2eba5ac7..e903d3383b74 100644 --- a/python/pyspark/sql/tests/test_readwriter.py +++ b/python/pyspark/sql/tests/test_readwriter.py @@ -16,6 +16,7 @@ # import os +import unittest import shutil import tempfile @@ -245,6 +246,8 @@ def test_create(self): df.writeTo("test_table").using("parquet").create() self.assertEqual(100, self.spark.sql("select * from test_table").count()) + @unittest.skipIf( + "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Known behavior change in 4.0") def test_create_without_provider(self): df = self.df with self.assertRaisesRegex(