[FLINK-33154] flink on k8s，An error occurred during consuming rocketmq

• Type: Technical Debt
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: kubernetes-operator-1.1.0
• Component/s: Kubernetes Operator
• Labels: RocketMQ flink-kubernetes-operator

Environment

flink-kubernetes-operator：https://github.com/apache/flink-kubernetes-operator#current-api-version-v1beta1
rocketmq-flink：https://github.com/apache/rocketmq-flink

Language

java scala

• Assignee: Unassigned
• Reporter: Monody
• Created: 25/Sep/23 10:58
• Updated: 23/Oct/23 07:46

Description

The following error occurs when flink consumes rocketmq. The flink job is running on k8s, and the projects used are:
The projects used by flink to consume rocketmq are:
The flink job runs normally on yarn, and no abnormality is found on the rocketmq server. Why does this happen? and how to solve it?