[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2965: Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved (was: Patch Available) Issue resolved by pull request 646 [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)
[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2965: Assignee: (was: Neha Narkhede) > 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 > 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)
[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2965: Assignee: Neha Narkhede > 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 > Labels: bug > 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)
[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhiqiang He updated KAFKA-2965: --- Labels: bug (was: patch) > 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 > 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)
[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Labels: patch (was: ) Reviewer: (was: Neha Narkhede) Status: Patch Available (was: Open) > 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: patch > 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)
[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Attachment: Kafka-2965.patch > 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 > 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)
[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Fix Version/s: (was: 0.9.1.0) > 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 > > 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)
[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Status: Open (was: Patch Available) > 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)
[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Reviewer: Neha Narkhede Fix Version/s: 0.9.1.0 Status: Patch Available (was: Open) > 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)
[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.
[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Description: 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 was:Two variables should be exchanged in KafkaController.scala as follows： > 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 > > 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)
