diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py index ccf39e1ffbe9..f1de286d57ea 100644 --- a/python/pyspark/rdd.py +++ b/python/pyspark/rdd.py @@ -141,7 +141,9 @@ def _parse_memory(s): def _load_from_socket(sock_info, serializer): - (sockfile, sock) = local_connect_and_auth(*sock_info) + port = sock_info[0] + auth_secret = sock_info[1] + (sockfile, sock) = local_connect_and_auth(port, auth_secret) # The RDD materialization time is unpredicable, if we set a timeout for socket reading # operation, it will very possibly fail. See SPARK-18281. sock.settimeout(None)