You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jim Hughes (Jira)" <ji...@apache.org> on 2026/06/29 13:19:00 UTC
[jira] [Updated] (FLINK-39728) KafkaPartitionSplitReader.pauseOrResumeSplits throws IllegalStateException on concurrently unassigned partitions
[ https://issues.apache.org/jira/browse/FLINK-39728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jim Hughes updated FLINK-39728:
-------------------------------
Description:
When `pauseOrResumeSplits` is add to the mailbox thread, the set of splits it operates on reflects the mailbox thread's view *at start time*.
By the time the SplitFetcher executes the action, a split may have already finished and been unassigned.
This can happen when the split-finished event has not yet propagated far enough to abort an in-flight alignment check on the `SourceOperator`. Calling `pause()` or `resume()` on a partition that is no longer in `consumer.assignment()` then throws `IllegalStateException`.
was:
When `pauseOrResumeSplits` is add to the mailbox thread, the set of splits it operates on reflects the mailbox thread's view *at start time*.
By the time the SplitFetcher executes the action, a split may have already finished and been unassigned.
This can happen when the split-finished event has not yet propagated far enough to abort an in-flight alignment check on the `SourceOperator`. Calling `pause()` or `resume()` on a partition that is no longer in `consumer.assignment()` then throws `IllegalStateException`.
Generated-by: Claude Opus 4.6 (Anthropic)
> KafkaPartitionSplitReader.pauseOrResumeSplits throws IllegalStateException on concurrently unassigned partitions
> ----------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-39728
> URL: https://issues.apache.org/jira/browse/FLINK-39728
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Reporter: Jim Hughes
> Assignee: Jim Hughes
> Priority: Major
> Labels: pull-request-available
> Fix For: kafka-5.1.0
>
>
> When `pauseOrResumeSplits` is add to the mailbox thread, the set of splits it operates on reflects the mailbox thread's view *at start time*.
> By the time the SplitFetcher executes the action, a split may have already finished and been unassigned.
> This can happen when the split-finished event has not yet propagated far enough to abort an in-flight alignment check on the `SourceOperator`. Calling `pause()` or `resume()` on a partition that is no longer in `consumer.assignment()` then throws `IllegalStateException`.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)