[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
-------------------------------
Description:
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 before kicking off the
record processing validation.
was:
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 skip the record processing validation when the assignment is
empty.
> StreamsUpgradeTest.test_metadata_upgrade could not guarantee all processor
> gets assigned task
> ---------------------------------------------------------------------------------------------
>
> 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: Boyang Chen
> Priority: Major
>
> 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 before kicking off the
> record processing validation.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
