You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Martijn Visser (Jira)" <ji...@apache.org> on 2023/03/09 08:48:00 UTC
[jira] [Commented] (FLINK-31371) Stream failure if the topic doesn't exist
[ https://issues.apache.org/jira/browse/FLINK-31371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17698258#comment-17698258 ]
Martijn Visser commented on FLINK-31371:
----------------------------------------
Downgraded priority per Flink' Jira process https://cwiki.apache.org/confluence/display/FLINK/Flink+Jira+Process
> Stream failure if the topic doesn't exist
> -----------------------------------------
>
> Key: FLINK-31371
> URL: https://issues.apache.org/jira/browse/FLINK-31371
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
> Affects Versions: 1.15.3
> Reporter: Enzo Dechaene
> Priority: Major
>
> *Describe the bug*
> With a Pulsar 2.8.4 server, a Flink stream containing Pulsar sources or sinks will fail at startup if the topic doesn't exist.
>
> *To Reproduce*
> Create a stream with :
> * Flink 1.15.2
> * Pulsar 2.8.4
> * with a Pulsar source or sink linked to a non existant topic
> * Start the stream
>
> *Expected behavior*
> If the topic doesn't exist, it should be created at the first connection of the source or sink without error.
>
> *Additional context*
> In the TopicListSubscriber class of the connector, the method getSubscribedTopicPartitions() try to get the metadata of a topic by doing that :
>
> {code:java}
> TopicMetadata metadata = queryTopicMetadata(pulsarAdmin, topic);{code}
>
> If the topic doesn't exist, I get a NullPointerException on the metadata
> We created a previous [ticket|https://github.com/streamnative/pulsar-flink/issues/366] on the Pulsar connector and it was fixed
--
This message was sent by Atlassian Jira
(v8.20.10#820010)