'PYARROW_IGNORE_TIMEZONE' environment variable was not set. It is required to set this environment variable to '1' in both driver and executor sides if you use pyarrow>=2.0.0. pandas-on-Spark will set it for you but it does not work if there is a Spark context already launched.
Running PySpark tests. Output is in /__w/spark/spark/python/unit-tests.log
Running PySpark tests. Output is in /__w/spark/spark/python/unit-tests.log
Will test against the following Python executables: ['python3.6', 'python3.9', 'pypy3']
Will test against the following Python executables: ['python3.6', 'python3.9', 'pypy3']
Will test the following Python modules: ['pyspark-core', 'pyspark-streaming', 'pyspark-ml']
Will test the following Python modules: ['pyspark-core', 'pyspark-streaming', 'pyspark-ml']
python3.6 python_implementation is CPython
python3.6 python_implementation is CPython
python3.6 version is: Python 3.6.13
python3.6 version is: Python 3.6.13
python3.9 python_implementation is CPython
python3.9 python_implementation is CPython
python3.9 version is: Python 3.9.5
python3.9 version is: Python 3.9.5
pypy3 python_implementation is PyPy
pypy3 python_implementation is PyPy
pypy3 version is: Python 3.7.10 (7.3.5+dfsg-1~ppa1~ubuntu20.04, May 23 2021, 14:57:07)
pypy3 version is: Python 3.7.10 (7.3.5+dfsg-1~ppa1~ubuntu20.04, May 23 2021, 14:57:07)
Skipped tests in pyspark.streaming.tests.test_dstream with pypy3:
Skipped tests in pyspark.streaming.tests.test_dstream with pypy3:
test_cogroup (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_cogroup (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_failed_func (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_failed_func (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_failed_func2 (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_failed_func2 (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_failed_func_with_reseting_failure (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_failed_func_with_reseting_failure (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_full_outer_join (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_full_outer_join (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_join (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_join (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_left_outer_join (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_left_outer_join (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_repartition (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_repartition (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_right_outer_join (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_right_outer_join (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_union (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_union (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_update_state_by_key (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_update_state_by_key (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_update_state_by_key_initial_rdd (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_update_state_by_key_initial_rdd (pyspark.streaming.tests.test_dstream.BasicOperationTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_get_or_create_and_get_active_or_create (pyspark.streaming.tests.test_dstream.CheckpointTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_get_or_create_and_get_active_or_create (pyspark.streaming.tests.test_dstream.CheckpointTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_transform_function_serializer_failure (pyspark.streaming.tests.test_dstream.CheckpointTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_transform_function_serializer_failure (pyspark.streaming.tests.test_dstream.CheckpointTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_count_by_value_and_window (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_count_by_value_and_window (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_count_by_window (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_count_by_window (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_count_by_window_large (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_count_by_window_large (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_group_by_key_and_window (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_group_by_key_and_window (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_reduce_by_invalid_window (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_reduce_by_invalid_window (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_reduce_by_key_and_window_with_none_invFunc (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_reduce_by_key_and_window_with_none_invFunc (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_window (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
test_window (pyspark.streaming.tests.test_dstream.WindowFunctionTests) ... skipped 'The tests fail in PyPy3 implementation for an unknown reason. With PyPy, it causes to hang DStream tests forever when Coverage report is used.'
Skipped tests in pyspark.streaming.tests.test_kinesis with pypy3:
Skipped tests in pyspark.streaming.tests.test_kinesis with pypy3:
test_kinesis_stream (pyspark.streaming.tests.test_kinesis.KinesisStreamTests) ... skipped "Skipping all Kinesis Python tests as environmental variable 'ENABLE_KINESIS_TESTS' was not set."
test_kinesis_stream (pyspark.streaming.tests.test_kinesis.KinesisStreamTests) ... skipped "Skipping all Kinesis Python tests as environmental variable 'ENABLE_KINESIS_TESTS' was not set."
test_kinesis_stream_api (pyspark.streaming.tests.test_kinesis.KinesisStreamTests) ... skipped "Skipping all Kinesis Python tests as environmental variable 'ENABLE_KINESIS_TESTS' was not set."
test_kinesis_stream_api (pyspark.streaming.tests.test_kinesis.KinesisStreamTests) ... skipped "Skipping all Kinesis Python tests as environmental variable 'ENABLE_KINESIS_TESTS' was not set."
Skipped tests in pyspark.streaming.tests.test_kinesis with python3.6:
Skipped tests in pyspark.streaming.tests.test_kinesis with python3.6: