Pulsar/Flink Error: PulsarAdminException$NotFoundException: Topic not exist

Hi, I am attempting to upgrade from 1.12.7 to 1.15.0. One of the issues I am encountering is the following exception when attempting to submit a job from the command line: switched from INITIALIZING to FAILED with failure cause:  org.apache.pulsar.client.admin.PulsarAdminException$NotFoundExcepti

[jira] [Created] (FLINK-33111) Flink Pulsar Connector to Pulsar Client Version Mismatch

Jason Kania created FLINK-33111: --- Summary: Flink Pulsar Connector to Pulsar Client Version Mismatch Key: FLINK-33111 URL: https://issues.apache.org/jira/browse/FLINK-33111 Project: Flink Issue

[jira] [Created] (FLINK-33135) Flink Pulsar Connector Attempts Partitioned Routing on Unpartitioned Topic

Jason Kania created FLINK-33135: --- Summary: Flink Pulsar Connector Attempts Partitioned Routing on Unpartitioned Topic Key: FLINK-33135 URL: https://issues.apache.org/jira/browse/FLINK-33135 Project

[jira] [Created] (FLINK-33136) Flink Pulsar Connector RoundRobinTopicRouter Generates Invalid Error Message

Jason Kania created FLINK-33136: --- Summary: Flink Pulsar Connector RoundRobinTopicRouter Generates Invalid Error Message Key: FLINK-33136 URL: https://issues.apache.org/jira/browse/FLINK-33136 Project

[jira] [Created] (FLINK-33486) Pulsar Client Send Timeout Terminates TaskManager

Jason Kania created FLINK-33486: --- Summary: Pulsar Client Send Timeout Terminates TaskManager Key: FLINK-33486 URL: https://issues.apache.org/jira/browse/FLINK-33486 Project: Flink Issue Type

[jira] [Created] (FLINK-16468) BlobClient rapid retrieval retries on failure opens too many sockets

Jason Kania created FLINK-16468: --- Summary: BlobClient rapid retrieval retries on failure opens too many sockets Key: FLINK-16468 URL: https://issues.apache.org/jira/browse/FLINK-16468 Project: Flink

[jira] [Created] (FLINK-16470) Network failure causes Checkpoint Coordinator to flood disk with exceptions

Jason Kania created FLINK-16470: --- Summary: Network failure causes Checkpoint Coordinator to flood disk with exceptions Key: FLINK-16470 URL: https://issues.apache.org/jira/browse/FLINK-16470 Project

[jira] [Created] (FLINK-16475) PulsarConsumerSource messageReceiveTimeoutMs parameter should be configurable

Jason Kania created FLINK-16475: --- Summary: PulsarConsumerSource messageReceiveTimeoutMs parameter should be configurable Key: FLINK-16475 URL: https://issues.apache.org/jira/browse/FLINK-16475 Project

[jira] [Created] (FLINK-15744) Some TaskManager Task exception are logged as info

Jason Kania created FLINK-15744: --- Summary: Some TaskManager Task exception are logged as info Key: FLINK-15744 URL: https://issues.apache.org/jira/browse/FLINK-15744 Project: Flink Issue Type

[jira] [Created] (FLINK-9371) High Availability JobManager Registration Failure

Jason Kania created FLINK-9371: -- Summary: High Availability JobManager Registration Failure Key: FLINK-9371 URL: https://issues.apache.org/jira/browse/FLINK-9371 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-11799) KryoSerializer/OperatorChain ignores copy failure resulting in NullPointerException

Jason Kania created FLINK-11799: --- Summary: KryoSerializer/OperatorChain ignores copy failure resulting in NullPointerException Key: FLINK-11799 URL: https://issues.apache.org/jira/browse/FLINK-11799

[jira] [Created] (FLINK-27568) Cannot submit JobGraph

Jason Kania created FLINK-27568: --- Summary: Cannot submit JobGraph Key: FLINK-27568 URL: https://issues.apache.org/jira/browse/FLINK-27568 Project: Flink Issue Type: Bug Affects Versions

[jira] [Created] (FLINK-27611) ConcurrentModificationException during Flink-Pulsar checkpoint notification

Jason Kania created FLINK-27611: --- Summary: ConcurrentModificationException during Flink-Pulsar checkpoint notification Key: FLINK-27611 URL: https://issues.apache.org/jira/browse/FLINK-27611 Project