py4j из pyspark - ошибка launch_gateway ()

Question

Шаг 1 - Я создал банку из примера кода Java - MyPythonGateway.jar

Java Class-

import py4j.GatewayServer;
public class MyPythonGateway{

    public int findMyNum(String input){
        return(1);
    }

    public static void main(String[] args){
        GatewayServer server = new Gatewayserver(new MyPythonGateway())
        server.start();
    }
}

Step2 - я вызываю pyspark, упоминая этот jar- MyPythonGateway.jar в executor.extraClassPath и driver.extraClassPath

pyspark запущен хорошо.

Step3 - пытается вызвать Java-код из pyspark сейчас

Ошибка: Py4jNetworkError: Произошла ошибка при попытке подключения к сервер Java (127.0.0.1:25335)

Я использовал другие порты, такие как 25340, 25338, но каждый раз получал одну и ту же ошибку