[
https://issues.apache.org/jira/browse/FLINK-39822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-39822:
-----------------------------------------
Assignee: Aleksandr Savonin
> All createTopics calls in tests should wait for partition assignment
> --------------------------------------------------------------------
>
> Key: FLINK-39822
> URL: https://issues.apache.org/jira/browse/FLINK-39822
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka
> Reporter: Aleksandr Savonin
> Assignee: Aleksandr Savonin
> Priority: Major
>
> We fixed a few occurrences previously seen in CI (a topic metadata
> propagation race addressed by {*}FLINK-39234{*}, {*}FLINK-39699{*}, and
> {*}FLINK-39723{*}).
> However, to prevent similar issues in other tests, I want to use this ticket
> as an umbrella ticket to track all calls that remain unprotected and fix them
> here.
> So far, I have found:
> {{KafkaSinkExternalContext.createTopic}} (not currently observed in CI, but I
> suggest to fix it beforehand).
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
