kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Damian Guy (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-4537) StreamPartitionAssignor incorrectly adds standby partitions to the partitionsByHostState map
Date Wed, 14 Dec 2016 11:10:58 GMT
Damian Guy created KAFKA-4537:
---------------------------------

             Summary: 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)

Mime
View raw message