[ https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Boyang Chen updated KAFKA-9989: ------------------------------- Summary: Wait for stable assignment StreamsUpgradeTest.test_metadata_upgrade (was: StreamsUpgradeTest.test_metadata_upgrade could not guarantee all processor gets assigned task) > Wait for stable assignment StreamsUpgradeTest.test_metadata_upgrade > -------------------------------------------------------------------- > > Key: KAFKA-9989 > URL: https://issues.apache.org/jira/browse/KAFKA-9989 > Project: Kafka > Issue Type: Bug > Components: streams, system tests > Reporter: Boyang Chen > Assignee: HaiyuanZhao > Priority: Major > Labels: newbie > Attachments: 166.tgz > > > System test StreamsUpgradeTest.test_metadata_upgrade could fail due to: > "Never saw output 'processed [0-9]* records' on ubuntu@worker6" > which if we take a closer look at, the rebalance happens but has no task > assignment. We should fix this problem by making the rebalance result as part > of the check, and wait for the finalized assignment (non-empty) before > kicking off the record processing validation. -- This message was sent by Atlassian Jira (v8.3.4#803005)