[ 
https://issues.apache.org/jira/browse/FLINK-9349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479259#comment-16479259
 ] 

Tzu-Li (Gordon) Tai edited comment on FLINK-9349 at 5/17/18 3:57 PM:
---------------------------------------------------------------------

[~Sergey Nuyanzin] this looks like a blocker bug that we probably should fix 
ASAP.
 Are you working on this already? If yes, do you have an ETA on the PR?
If possible, we should try to get this fix in 1.5.0, which is just around the 
corner.


was (Author: tzulitai):
[~Sergey Nuyanzin] this looks like a blocker bug that we probably should fix 
ASAP.
Are you working on this already? If yes, do you have an ETA on the PR?
Otherwise, if it's okay, I would like to work on this.

> KafkaConnector Exception  while fetching from multiple kafka topics
> -------------------------------------------------------------------
>
>                 Key: FLINK-9349
>                 URL: https://issues.apache.org/jira/browse/FLINK-9349
>             Project: Flink
>          Issue Type: Bug
>          Components: Kafka Connector
>    Affects Versions: 1.4.0
>            Reporter: Vishal Santoshi
>            Priority: Major
>         Attachments: Flink9349Test.java
>
>
> ./flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka09Fetcher.java
>  
> It seems the List subscribedPartitionStates was being modified when 
> runFetchLoop iterated the List.
> This can happen if, e.g., FlinkKafkaConsumer runs the following code 
> concurrently:
>                 kafkaFetcher.addDiscoveredPartitions(discoveredPartitions);
>  
> {code:java}
>  java.util.ConcurrentModificationException
>       at 
> java.util.LinkedList$ListItr.checkForComodification(LinkedList.java:966)
>       at java.util.LinkedList$ListItr.next(LinkedList.java:888)
>       at 
> org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher.runFetchLoop(Kafka09Fetcher.java:134)
> {code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to