rocketmq-flink
rocketmq-flink copied to clipboard
Run on k8s, it's throw RemotingTimeoutException
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?
这个感觉还是和 k8s 的一些机制有关啊,可以用 mtr 之类的追踪一下看看