[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15049090#comment-15049090 ]
ASF GitHub Bot commented on KAFKA-2965: --------------------------------------- Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/646 > Two variables should be exchanged. > ---------------------------------- > > Key: KAFKA-2965 > URL: https://issues.apache.org/jira/browse/KAFKA-2965 > Project: Kafka > Issue Type: Bug > Components: controller > Affects Versions: 0.9.0.0 > Environment: NA > Reporter: Bo Wang > Priority: Minor > Labels: bug > Fix For: 0.9.1.0 > > Attachments: Kafka-2965.patch > > > Two variables should be exchanged in KafkaController.scala as follows: > val topicsForWhichPartitionReassignmentIsInProgress = > controllerContext.partitionsUndergoingPreferredReplicaElection.map(_.topic) > val topicsForWhichPreferredReplicaElectionIsInProgress = > controllerContext.partitionsBeingReassigned.keySet.map(_.topic) > val topicsIneligibleForDeletion = topicsWithReplicasOnDeadBrokers | > topicsForWhichPartitionReassignmentIsInProgress | > > topicsForWhichPreferredReplicaElectionIsInProgress > Should change to: > val topicsForWhichPreferredReplicaElectionIsInProgress = > controllerContext.partitionsUndergoingPreferredReplicaElection.map(_.topic) > val topicsForWhichPartitionReassignmentIsInProgress = > controllerContext.partitionsBeingReassigned.keySet.map(_.topic) > val topicsIneligibleForDeletion = topicsWithReplicasOnDeadBrokers | > topicsForWhichPartitionReassignmentIsInProgress | > > topicsForWhichPreferredReplicaElectionIsInProgress -- This message was sent by Atlassian JIRA (v6.3.4#6332)