[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047855#comment-15047855 ]
Bo Wang commented on KAFKA-2965: -------------------------------- According to the code, I think the name of the two variable needs to be exchanged. > 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 > Assignee: Neha Narkhede > Priority: Minor > Fix For: 0.9.1.0 > > > 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)