diff --git a/python/pyspark/tests/test_worker.py b/python/pyspark/tests/test_worker.py index ebf1e932fd6d6..b9b7306633367 100644 --- a/python/pyspark/tests/test_worker.py +++ b/python/pyspark/tests/test_worker.py @@ -16,6 +16,7 @@ # limitations under the License. # import os +import sys import tempfile import threading import time @@ -188,9 +189,9 @@ def test_reuse_worker_of_parallelize_range(self): @unittest.skipIf( - not has_resource_module, + not has_resource_module or sys.platform != 'linux', "Memory limit feature in Python worker is dependent on " - "Python's 'resource' module; however, not found.") + "Python's 'resource' module on Linux; however, not found or not on Linux.") class WorkerMemoryTest(unittest.TestCase): def setUp(self):