虽然 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可以被访问
- 让 nebula-flink 运行在 docker-compose docker 网络里 比如
nebula-docker-compose_nebula-net
- 配置 meta的 地址为它暴露给 0.0.0.0 的那个端口而不是 9559
或者其他方法
1 个赞
读报错原因是因为端口映射问题,storaged地址是metad服务返回的,返回出来的是容器内的地址,外面自然就访问不了了。
1 个赞
多谢 @nicole ,报错是按照 meta给客户端返回的 storaged0:9779 没法直连 strorageD 对吧,那这个compose的测试 flink 场景推荐的最佳实践是什么?
- 让 flinkConnector 跑在 nebula-net 网络里?
@Leshrac 填meta的端口。 内部使用的storage地址是由metad返回出来的,应该是这样一个地址 storaged:9779, 然后你的flink connector是执行在容器外的,所以访问不了这个 storaged:9779
地址。
好的,明白了,多谢