[
https://issues.apache.org/jira/browse/FLINK-33154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17778512#comment-17778512
]
Monody commented on FLINK-33154:
--------------------------------
[~martijnvisser] hi~ Thank you for paying attention to this issue. I'm using
[rocketmq-flink connector|https://github.com/apache/rocketmq-flink], It is
production ready.
This leaves me wondering where the problem might be, do you have any possible
guesses?
> 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)
