You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Leo zhang (Jira)" <ji...@apache.org> on 2022/08/29 08:21:00 UTC

[jira] [Created] (FLINK-29128) Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader

Leo zhang created FLINK-29128:
---------------------------------

             Summary: Uncatch IllegalStateException found when log split changes handling result in KafkaPartitionSplitReader
                 Key: FLINK-29128
                 URL: https://issues.apache.org/jira/browse/FLINK-29128
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
    Affects Versions: 1.15.2, 1.14.5
            Reporter: Leo zhang


When logger is set to debug mode, KafkaPartitionSplitReader#maybeLogSplitChangesHandingResult log the handing result of all  SplitsChange<KafkaPartitionSplit>, and the handling result include the kafka partition's starting offset, which is get from kafka api(consumer.position).

When a SplitsChange<KafkaPartitionSplit> is a empty split,it will be removed(unassign partition), IllegalStateException will be thrown by consumer.position, since we can only check the position for partitions assigned to the consumer.And this exception has not been catch, and is rethrown as RuntimeExption, which lead to a failure of the application's execution.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)