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

Posted to dev@kafka.apache.org by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2016/12/16 00:50:59 UTC

[jira] [Resolved] (KAFKA-4537) StreamPartitionAssignor incorrectly adds standby partitions to the partitionsByHostState map

     [ https://issues.apache.org/jira/browse/KAFKA-4537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Guozhang Wang resolved KAFKA-4537.
----------------------------------
    Resolution: Fixed

Issue resolved by pull request 2254
[https://github.com/apache/kafka/pull/2254]

> StreamPartitionAssignor incorrectly adds standby partitions to the partitionsByHostState map
> --------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-4537
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4537
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams
>    Affects Versions: 0.10.2.0
>            Reporter: Damian Guy
>            Assignee: Damian Guy
>             Fix For: 0.10.2.0
>
>
> If a KafkaStreams app is using Standby Tasks then StreamPartitionAssignor will add the standby partitions to the partitionsByHostState map for each host. This is incorrect as the partitionHostState map is used to resolve which host is hosting a particular store for a key. 
> The result is that doing metadata lookups for interactive queries can return an incorrect host



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)