[jira] [Resolved] (KAFKA-10300) fix flaky core/group_mode_transactions_test.py

["Jun Rao (Jira)" <ji...@apache.org>]

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

Jun Rao resolved KAFKA-10300.
-----------------------------
    Fix Version/s: 2.7.0
       Resolution: Fixed

merged to trunk

> fix flaky core/group_mode_transactions_test.py
> ----------------------------------------------
>
>                 Key: KAFKA-10300
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10300
>             Project: Kafka
>          Issue Type: Bug
>          Components: core, system tests
>            Reporter: Chia-Ping Tsai
>            Assignee: Chia-Ping Tsai
>            Priority: Major
>             Fix For: 2.7.0
>
>
> {quote}
> test_id:    kafkatest.tests.core.group_mode_transactions_test.GroupModeTransactionsTest.test_transactions.failure_mode=hard_bounce.bounce_target=brokers
> status:     FAIL
> run time:   9 minutes 47.698 seconds
>  
>  
>     copier-0 - Failed to copy all messages in 240s.
> Traceback (most recent call last):
>   File "/usr/local/lib/python2.7/dist-packages/ducktape/tests/runner_client.py", line 134, in run
>     data = self.run_test()
>   File "/usr/local/lib/python2.7/dist-packages/ducktape/tests/runner_client.py", line 192, in run_test
>     return self.test_context.function(self.test)
>   File "/usr/local/lib/python2.7/dist-packages/ducktape/mark/_mark.py", line 429, in wrapper
>     return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
>   File "/opt/kafka-dev/tests/kafkatest/tests/core/group_mode_transactions_test.py", line 271, in test_transactions
>     num_messages_to_copy=self.num_seed_messages)
>   File "/opt/kafka-dev/tests/kafkatest/tests/core/group_mode_transactions_test.py", line 230, in copy_messages_transactionally
>     (copier.transactional_id, copier_timeout_sec))
>   File "/usr/local/lib/python2.7/dist-packages/ducktape/utils/util.py", line 41, in wait_until
>     raise TimeoutError(err_msg() if callable(err_msg) else err_msg)
> TimeoutError: copier-0 - Failed to copy all messages in 240s.
> {quote}
>  
> this issue is same to KAFKA-10274 so we can apply the same approach



--
This message was sent by Atlassian Jira
(v8.3.4#803005)