在哪台机器上报的错, 就在对应那台机器的/etc/hosts里加上域名解析
并且确保解析出的IP是可以连通的.
在哪台机器上报的错, 就在对应那台机器的/etc/hosts里加上域名解析
并且确保解析出的IP是可以连通的.
都配置成一个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信息:
本地idea flink写入k8s中的starrocks报错信息:
其中10.30.6.80是10.30.6.70,10.30.6.68,10.30.6.67三台机器的VIP
奇怪的是,flink写入报错,但数据是写入到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
这个我是通过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
兄弟,这个问题解决了吗,我也遇到了这个问题