nebula-flink报错



跑demo报得错~

虽然 IDE 的小姐姐很好看,但是你也得补齐下 Nebula Graph 和 Flink 工具的版本号呀。以及你的 Nebula Graph 是 Docker 部署的?

Nebula Graph 2.0
Flink 1.11.3
使用的demo地址: https://github.com/vesoft-inc/nebula-flink-connector
除了ip,port换了,其他都没动,写入的通了,读报错~

使用的docker-compose方式部署的

@Leshrac
正常 docker-compose 来起来的 nebula,只有 graphD 的端口是以 0.0.0.0:9669 暴露给外部的 (docker ps 可以看到, metaD是类似于 0.0.0.0:49218->9559/tcp
您可以用 telnet 试验一下

telnet a.b.c.d 9669
telnet a.b.c.d 9559

您可以用一些办法让meta可以被访问

  1. 让 nebula-flink 运行在 docker-compose docker 网络里 比如nebula-docker-compose_nebula-net
  2. 配置 meta的 地址为它暴露给 0.0.0.0 的那个端口而不是 9559
    或者其他方法
1 个赞

读报错原因是因为端口映射问题,storaged地址是metad服务返回的,返回出来的是容器内的地址,外面自然就访问不了了。

1 个赞

yaml改过了,metad,graphd,storaged各往外部暴露了一个端口,telnet 9669,9559,9779都是通的


image
image


这里要使用的storaged端口吗?

多谢 @nicole ,报错是按照 meta给客户端返回的 storaged0:9779 没法直连 strorageD 对吧,那这个compose的测试 flink 场景推荐的最佳实践是什么?

  • 让 flinkConnector 跑在 nebula-net 网络里?

@Leshrac 填meta的端口。 内部使用的storage地址是由metad返回出来的,应该是这样一个地址 storaged:9779, 然后你的flink connector是执行在容器外的,所以访问不了这个 storaged:9779地址。

好的,明白了,多谢