diff --git a/python/pyspark/util.py b/python/pyspark/util.py index 4ab78caf52c0..e07474db9269 100644 --- a/python/pyspark/util.py +++ b/python/pyspark/util.py @@ -25,7 +25,10 @@ import threading import traceback import types -from collections import Callable +try: + from collections.abc import Callable +except AttributeError: + from collections import Callable from py4j.clientserver import ClientServer