Chia-Ping Tsai created KAFKA-18976:
--------------------------------------
Summary: fix flaky connect_distributed_test
Key: KAFKA-18976
URL: https://issues.apache.org/jira/browse/KAFKA-18976
Project: Kafka
Issue Type: Improvement
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai
{code:java}
TimeoutError('Kafka Connect process on ubuntu@worker16 took too long to exit')
Traceback (most recent call last):
File
"/home/semaphore/kafka-overlay/kafka/venv/lib/python3.8/site-packages/ducktape/tests/runner_client.py",
line 351, in _do_run
data = self.run_test()
File
"/home/semaphore/kafka-overlay/kafka/venv/lib/python3.8/site-packages/ducktape/tests/runner_client.py",
line 411, in run_test
return self.test_context.function(self.test)
File
"/home/semaphore/kafka-overlay/kafka/venv/lib/python3.8/site-packages/ducktape/mark/_mark.py",
line 438, in wrapper
return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs)
File
"/home/semaphore/kafka-overlay/kafka/tests/kafkatest/tests/connect/connect_distributed_test.py",
line 727, in test_bounce
self._restart_worker(node, clean=clean)
File
"/home/semaphore/kafka-overlay/kafka/tests/kafkatest/tests/connect/connect_distributed_test.py",
line 1052, in _restart_worker
self.cc.stop_node(node, clean_shutdown=clean, await_shutdown=True)
File
"/home/semaphore/kafka-overlay/kafka/tests/kafkatest/services/connect.py", line
166, in stop_node
wait_until(lambda: not node.account.alive(pid),
timeout_sec=self.startup_timeout_sec, err_msg="Kafka Connect process on " + str(
File
"/home/semaphore/kafka-overlay/kafka/venv/lib/python3.8/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: Kafka Connect process on ubuntu@worker16 took too
long to exit
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
