py4j来自pyspark launch\u gateway（）

Question

步骤1-我用示例java代码创建了一个jar-MyPythonGateway.jar文件

Java类-

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();
    }
}

第二步-我在调用pyspark时提到了这个jar-MyPythonGateway.jar文件在executor.extraClassPath文件以及驱动程序.extraClassPath你知道吗

Pypark发射良好。你知道吗

第3步-现在尝试从pyspark调用java代码

Error: Py4jNetworkError: An Error occurred while trying to connect to the Java server (127.0.0.1:25335)

我使用了其他端口，如-25340、25338，但每次都会出现相同的错误