本地无法通过StreamLoad写入K8S中的StarRocks集群

在哪台机器上报的错, 就在对应那台机器的/etc/hosts里加上域名解析

并且确保解析出的IP是可以连通的.


我本地的网络和 物理机(10.30.6.73)网络是通的,starrocks集群(3fe3be)装在物理机上,本地host是图中那样配置的].

都配置成一个ip不行吧,区别不出来是哪个BE

那该如何配置呢?配置成k8s的虚拟ip?

我就想实现本地通过IDEA连接远程k8s中的starrocks集群做产品功能调试。

对, 远程的虚拟IP并且这些虚拟IP是可以直接连通的, 否则无法使用. k8s集群内部的网络默认是和外部隔离的.

我开启了nodeport,使用k8s宿主机IP:nodeport端口,不能在本地连上容器里的starrocks吗? 通过nodeport形式,我能在本地正常连接k8s里的kafka集群。
kafka deployment:

本地idea中的kafka连接配置:

本地idea中的starrocks连接配置:

本地host配置:

k8s集群中的starrocks信息:


本地浏览器连接信息:
使用VIP:nodeport(10.30.6.80:30425)

本地idea flink写入k8s中的starrocks报错信息:

该如何避免这个报错呢?

本地/etc/hosts添加了fe的映射信息,将starrocks flink connector升级到1.2.6_flink-1.13_2.11,


报错如下:

k8s的starrocks集群不是一个简单的单节点服务, 涉及到FE和BE, 在与k8s里的FE交互时, FE会返回BE在k8s的内部地址和port, 这个内部IP地址和PORT不是能用nodePort方式绕过去的. 所以会有大量网络访问相关的问题出现.

你好,请问下k8s集群中的starrocks信息NodePort如何配置的?谢谢

那该如何解决呢?

信息如下

这个我看到了,但是我配置了几次一直不生效,请问你是通过这个方式配置的吗?
kubectl -n starrocks edit src starrockscluster-sample
企业微信截图_20230508174200


企业微信截图_16835400769199
可以看下你这个配置吗,谢谢

这个我是通过kubesphere页面操作开启nodeport做测试的,starrocks yaml里没有配置nodeport

谢谢,搞定了!!!

你那边可以在本地连接远程K8S集群里的Starrocks吗?

开通外部访问端口,就可以了

有测试过本地flink往k8s中的starrocks集群写数据吗

[quote=“U_1654075414197_7021, post:21, topic:6626”]
过本地flink往k8s
[/quote]刚试了下,用kafka topic数据可以写入starrocks

Caused by: java.lang.RuntimeException: java.net.UnknownHostException: starrockscluster-be-0.starrockscluster-be-search.starrocks.svc.cluster.local

我也碰到Flink写入Starrocks的错误,请问最后是怎么解决呢?
用的版本是这个

com.starrocks
flink-connector-starrocks
1.2.8_flink-1.17

兄弟,这个问题解决了吗,我也遇到了这个问题