diff --git a/python/pyspark/sql/tests/pandas/test_pandas_transform_with_state.py b/python/pyspark/sql/tests/pandas/test_pandas_transform_with_state.py index 183e93a871bd8..7a00f2f43d149 100644 --- a/python/pyspark/sql/tests/pandas/test_pandas_transform_with_state.py +++ b/python/pyspark/sql/tests/pandas/test_pandas_transform_with_state.py @@ -922,6 +922,9 @@ def test_transform_with_state_in_pandas_batch_query_initial_state(self): # This test covers mapState with TTL, an empty state variable # and additional test against initial state python runner + @unittest.skipIf( + "COVERAGE_PROCESS_START" in os.environ, "Flaky with coverage enabled, skipping for now." + ) def test_transform_with_map_state_metadata(self): checkpoint_path = tempfile.mktemp()