Star

spark reader 1.1.0 运行报错

虚拟机 rpm 安装 1.1.0版本 nebula graph
运行nebula-spark 1.1.0版本的例子NebulaReaderExample报错

SparkSession sparkSession = SparkSession
                .builder()
                .config(sparkConf)
                .master("local[4]")
                .getOrCreate();

        Dataset<Row> vertexDataset = sparkSession
                .read()
                .format("nebula")
                .option(Parameters.TYPE, Type.VERTEX.getType())
                .option(Parameters.HOST_AND_PORTS, "192.168.137.111:45500")
                .option(Parameters.PARTITION_NUMBER, "100")
                .option(Parameters.SPACE_NAME, "test")
                .option(Parameters.LABEL, "student")
                // if configuration "returnCols" is null or "", then return all cols
                .option(Parameters.RETURN_COLS, "")
                .load();
        LOGGER.info("vertex course schema: ");
        vertexDataset.printSchema();
        vertexDataset.show();

Caused by: com.vesoft.nebula.exception.GraphOperateException: Failed to connect 127.0.0.1:44500
44500这个端口应该是集群心跳端口,不清楚这为啥会请求

你好,有检查过端口是否被占用吗?

根据你的报错, 你检查一下 etc 目录下meta storage graph的ip port 是否配置准确
之后用nebula.service 脚本检查服务是否运行正常

服务通过命令看都是正常的,nebula我是在虚拟机跑的,程序是在本机调试,不太清楚本机为啥会访问127.0.0.1的44500这个端口 是否是配置信息是配的45500原信息端口 连上后程序会连44500这个storage端口查数据?

问题找到了哈,因为之前安装完没改ip, 后来改了ip 没有清理元数据,导致的问题,谢谢哈

浙ICP备20010487号