You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Jason Kania <ja...@ymail.com> on 2022/05/12 16:28:42 UTC

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$NotFoundException: Topic not exist        at org.apache.pulsar.client.admin.internal.BaseResource.getApiException(BaseResource.java:230)        at org.apache.pulsar.client.admin.internal.TopicsImpl$7.failed(TopicsImpl.java:529)        at org.apache.pulsar.shade.org.glassfish.jersey.client.JerseyInvocation$1.failed(JerseyInvocation.java:882)        at org.apache.pulsar.shade.org.glassfish.jersey.client.JerseyInvocation$1.completed(JerseyInvocation.java:863)        at org.apache.pulsar.shade.org.glassfish.jersey.client.ClientRuntime.processResponse(ClientRuntime.java:229)        at org.apache.pulsar.shade.org.glassfish.jersey.client.ClientRuntime.access$200(ClientRuntime.java:62)        at org.apache.pulsar.shade.org.glassfish.jersey.client.ClientRuntime$2.lambda$response$0(ClientRuntime.java:173)        at org.apache.pulsar.shade.org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)        at org.apache.pulsar.shade.org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)
Unfortunately, the exception does not name the topic that does not exist specifically. Additionally, I would expect that the topic would be created automatically as it has in the past under the use of Pulsar.
Can someone confirm if topics must now be created manually? If not, what parameter must be set to have the topic automatically created. I am likely missing it, but could not see.
Thanks