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)

Reply via email to