每当我尝试在pyspark中使用als来拟合我的模型时，我都会遇到这个错误。有人能帮忙吗？

Exception happened during processing of request from ('127.0.0.1', 55552)
    Traceback (most recent call last):
      File "C:\Users\wtibr\anaconda3\lib\socketserver.py", line 316, in _handle_request_noblock
        self.process_request(request, client_address)
      File "C:\Users\wtibr\anaconda3\lib\socketserver.py", line 347, in process_request
        self.finish_request(request, client_address)`enter code here`
      File "C:\Users\wtibr\anaconda3\lib\socketserver.py", line 360, in finish_request
        self.RequestHandlerClass(request, client_address, self)
      File "C:\Users\wtibr\anaconda3\lib\socketserver.py", line 720, in __init__
        self.handle()
      File "C:\spark\spark\python\pyspark\accumulators.py", line 269, in handle
        poll(accum_updates)
      File "C:\spark\spark\python\pyspark\accumulators.py", line 241, in poll
        if func():
      File "C:\spark\spark\python\pyspark\accumulators.py", line 245, in accum_updates
        num_updates = read_int(self.rfile)
      File "C:\spark\spark\python\pyspark\serializers.py", line 722, in read_int
        length = stream.read(4)
      File "C:\Users\wtibr\anaconda3\lib\socket.py", line 589, in readinto
        return self._sock.recv_into(b)
    ConnectionResetError: [WinError 10054] An existing connection was forcibly closed by the remote host
    ----------------------------------------

代码如下：