Run on k8s, it's throw RemotingTimeoutException

apache / rocketmq-flink

RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.

https://rocketmq.apache.org/

Apache License 2.0

139 stars 88 forks source link

Run on k8s, it's throw RemotingTimeoutException #100

Open SOD-DOB opened 9 months ago

SOD-DOB commented 9 months ago

my Flink Job run on k8s with flink-kubernetes-operator https://github.com/apache/flink-kubernetes-operator

Tasks always report errors from time to time, but it doesn’t always appear

but when I execute it on the yarn cluster, this error will not appear again.

rocketmq cluster status is normal.

does anyone have the same problem?

lizhimins commented 7 months ago

这个感觉还是和 k8s 的一些机制有关啊，可以用 mtr 之类的追踪一下看看