m1a2st commented on PR #18005: URL: https://github.com/apache/kafka/pull/18005#issuecomment-2513558911
Hello @chia7712 I ran `TC_PATHS="tests/kafkatest/tests/connect/connect_distributed_test.py" /bin/bash tests/docker/run_tests.sh` in my local machine  There are three test fail, but I am not sure we should fix these fail tests in this PR, We can add new Jira to trace these issues, WDYT? ``` test_id: kafkatest.tests.connect.connect_distributed_test.ConnectDistributedTest.test_pause_and_resume_sink.connect_protocol=sessioned.metadata_quorum=ISOLATED_KRAFT.use_new_coordinator=True.group_protocol=consumer status: FAIL run time: 1 minute 18.121 seconds TimeoutError('Failed to consume messages after resuming sink connector') Traceback (most recent call last): File "/usr/local/lib/python3.7/dist-packages/ducktape/tests/runner_client.py", line 351, in _do_run data = self.run_test() File "/usr/local/lib/python3.7/dist-packages/ducktape/tests/runner_client.py", line 411, in run_test return self.test_context.function(self.test) File "/usr/local/lib/python3.7/dist-packages/ducktape/mark/_mark.py", line 438, in wrapper return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs) File "/opt/kafka-dev/tests/kafkatest/tests/connect/connect_distributed_test.py", line 416, in test_pause_and_resume_sink err_msg="Failed to consume messages after resuming sink connector") File "/usr/local/lib/python3.7/dist-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: Failed to consume messages after resuming sink connector ``` ``` test_id: kafkatest.tests.connect.connect_distributed_test.ConnectDistributedTest.test_pause_and_resume_sink.connect_protocol=compatible.metadata_quorum=ISOLATED_KRAFT.use_new_coordinator=True.group_protocol=consumer status: FAIL run time: 1 minute 19.327 seconds TimeoutError('Failed to consume messages after resuming sink connector') Traceback (most recent call last): File "/usr/local/lib/python3.7/dist-packages/ducktape/tests/runner_client.py", line 351, in _do_run data = self.run_test() File "/usr/local/lib/python3.7/dist-packages/ducktape/tests/runner_client.py", line 411, in run_test return self.test_context.function(self.test) File "/usr/local/lib/python3.7/dist-packages/ducktape/mark/_mark.py", line 438, in wrapper return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs) File "/opt/kafka-dev/tests/kafkatest/tests/connect/connect_distributed_test.py", line 416, in test_pause_and_resume_sink err_msg="Failed to consume messages after resuming sink connector") File "/usr/local/lib/python3.7/dist-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: Failed to consume messages after resuming sink connector ``` ``` test_id: kafkatest.tests.connect.connect_distributed_test.ConnectDistributedTest.test_dynamic_logging.metadata_quorum=ISOLATED_KRAFT status: FAIL run time: 35.884 seconds AssertionError() Traceback (most recent call last): File "/usr/local/lib/python3.7/dist-packages/ducktape/tests/runner_client.py", line 351, in _do_run data = self.run_test() File "/usr/local/lib/python3.7/dist-packages/ducktape/tests/runner_client.py", line 411, in run_test return self.test_context.function(self.test) File "/usr/local/lib/python3.7/dist-packages/ducktape/mark/_mark.py", line 438, in wrapper return functools.partial(f, *args, **kwargs)(*w_args, **w_kwargs) File "/opt/kafka-dev/tests/kafkatest/tests/connect/connect_distributed_test.py", line 469, in test_dynamic_logging assert len(initial_loggers) >= 2 AssertionError ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
