[ https://issues.apache.org/jira/browse/FLINK-33154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770278#comment-17770278 ]
Martijn Visser commented on FLINK-33154: ---------------------------------------- I would think this isn't necessarily a Kubernetes Operator problem, but given that there's no Flink project owned/supported RocketMQ connector, I would wonder if the issue actually resides in the connector. The operator doesn't do anything special when it comes to connector artifacts. > flink on k8s,An error occurred during consuming rocketmq > -------------------------------------------------------- > > Key: FLINK-33154 > URL: https://issues.apache.org/jira/browse/FLINK-33154 > Project: Flink > Issue Type: Technical Debt > Components: Kubernetes Operator > Affects Versions: kubernetes-operator-1.1.0 > Environment: > flink-kubernetes-operator:https://github.com/apache/flink-kubernetes-operator#current-api-version-v1beta1 > rocketmq-flink:https://github.com/apache/rocketmq-flink > Reporter: Monody > Priority: Major > Labels: RocketMQ, flink-kubernetes-operator > > 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? > !https://user-images.githubusercontent.com/47728686/265662530-231c500c-fd64-4679-9b0f-ff4a025dd766.png! -- This message was sent by Atlassian Jira (v8.20.10#820010)