[ https://issues.apache.org/jira/browse/KAFKA-16141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807890#comment-17807890 ]
Matthias J. Sax commented on KAFKA-16141: ----------------------------------------- After discussion with Almog (and testing it) implementing `WrappedStateStore` won't do the trick. Given that this is a regression, it seems best (most pragmatic) to just revert the change on `KeyValueToTimestampedKeyValueByteStoreAdapter` and don't let it implement `TimestampedBytesStore` for now (even if this still seems to be the right thing to do – however, it might require some larger changes to make it work – will file a follow up ticket for this). > StreamsStandbyTask##test_standby_tasks_rebalanceArguments:{ > “metadata_quorum”: “ISOLATED_KRAFT”, “use_new_coordinator”: false} fails > consistently in 3.7 > -------------------------------------------------------------------------------------------------------------------------------------------------------- > > Key: KAFKA-16141 > URL: https://issues.apache.org/jira/browse/KAFKA-16141 > Project: Kafka > Issue Type: Test > Affects Versions: 3.7.0 > Reporter: Stanislav Kozlovski > Assignee: Matthias J. Sax > Priority: Blocker > > {code:java} > kafkatest.tests.streams.streams_standby_replica_test.StreamsStandbyTask#test_standby_tasks_rebalanceArguments:{ > “metadata_quorum”: “ISOLATED_KRAFT”, “use_new_coordinator”: false} > TimeoutError("Did expect to read 'ACTIVE_TASKS:2 STANDBY_TASKS:[1-3]' from > ubuntu@worker26") > Traceback (most recent call last): > File > "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python3.7/site-packages/ducktape/tests/runner_client.py", > line 184, in _do_run > data = self.run_test() > File > "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python3.7/site-packages/ducktape/tests/runner_client.py", > line 262, in run_test > return self.test_context.function(self.test) > File > "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python3.7/site-packages/ducktape/mark/_mark.py", > line 433, in wrapper > return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs) > File > "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/tests/kafkatest/tests/streams/streams_standby_replica_test.py", > line 79, in test_standby_tasks_rebalance > self.wait_for_verification(processor_1, "ACTIVE_TASKS:2 > STANDBY_TASKS:[1-3]", processor_1.STDOUT_FILE) > File > "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/tests/kafkatest/tests/streams/base_streams_test.py", > line 96, in wait_for_verification > err_msg="Did expect to read '%s' from %s" % (message, > processor.node.account)) > File > "/home/jenkins/workspace/system-test-kafka-branch-builder/kafka/venv/lib/python3.7/site-packages/ducktape/utils/util.py", > line 58, in wait_until > raise TimeoutError(err_msg() if callable(err_msg) else err_msg) from > last_exception > ducktape.errors.TimeoutError: Did expect to read 'ACTIVE_TASKS:2 > STANDBY_TASKS:[1-3]' from ubuntu@worker26 > {code} > -- This message was sent by Atlassian Jira (v8.20.10#820010)