You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "HeYe (Jira)" <ji...@apache.org> on 2021/12/06 08:11:00 UTC
[jira] [Created] (FLINK-25182) NoClassDefFoundError of PulsarAdminImpl by using flink-connector-pulsar:1.14 on k8s flink cluster
HeYe created FLINK-25182:
----------------------------
Summary: NoClassDefFoundError of PulsarAdminImpl by using flink-connector-pulsar:1.14 on k8s flink cluster
Key: FLINK-25182
URL: https://issues.apache.org/jira/browse/FLINK-25182
Project: Flink
Issue Type: Bug
Components: Connectors / Pulsar
Affects Versions: 1.14.0
Environment: Flink: HA cluster on k8s
Flink Mode: session
Version: Flink 1.14.0
Connector: flink-connector-pulsar_2.11:1.14.0
Pulsar cluster: ( by StreamNative' s helm charts)
broker version: 2.8.0.8
bookie version: 2.7.2.8
pulsar proxy: 2.8.0.8
Reporter: HeYe
Attachments: image-2021-12-06-16-09-12-816.png, image-2021-12-06-16-09-52-042.png, image-2021-12-06-16-10-13-697.png
NoClassDefFoundError of PulsarAdminImpl by using flink-connector-pulsar:1.14 on k8s flink cluster
Flink: Session mode in HA cluster on k8s
Version: Flink 1.14.0
Connector: flink-connector-pulsar_2.11:1.14.0
The connector is worked by using IntelliJ IDEA, but meets exception on dev k8s clusters, the exception please check screenshot
!image-2021-12-06-16-09-12-816.png!
!image-2021-12-06-16-09-52-042.png!
!image-2021-12-06-16-10-13-697.png!
--
This message was sent by Atlassian Jira
(v8.20.1#820001)