brandboat commented on PR #16646:
URL: https://github.com/apache/kafka/pull/16646#issuecomment-2289176368
> Could you share the details to me ? I run the e2e on trunk, all pass
Interesting... After ran
`TC_PATHS="tests/kafkatest/benchmarks/core/benchmark_test.py" bash
tests/docker/run_tests.sh` in trunk branch, I got bunch of errors as follows
```
[INFO:2024-08-14 08:52:07,138]: Triggering test 2 of 62...
[INFO:2024-08-14 08:52:07,148]: RunnerClient: Loading test {'directory':
'/opt/kafka-dev/tests/kafkatest/benchmarks/core', 'file_name':
'benchmark_test.py', 'cls_name': 'Benchmark', 'method_name':
'test_consumer_throughput', 'injected_args': {'security_protocol': 'PLAINTEXT',
'compression_type': 'none'}}
[INFO:2024-08-14 08:52:07,154]: RunnerClient:
kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.security_protocol=PLAINTEXT.compression_type=none:
on run 1/1
[INFO:2024-08-14 08:52:07,156]: RunnerClient:
kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.security_protocol=PLAINTEXT.compression_type=none:
Setting up...
[INFO:2024-08-14 08:52:09,266]: RunnerClient:
kafkatest.benchmarks.core.benchmark_test.Benchmark.test_consumer_throughput.security_protocol=PLAINTEXT.compression_type=none:
Running...
Exception in thread ProducerPerformanceService-0-127377594939280-worker-1:
Traceback (most recent call last):
File
"/opt/kafka-dev/tests/kafkatest/services/performance/producer_performance.py",
line 157, in _worker
self.results[idx-1] = self.parse_stats(last)
File
"/opt/kafka-dev/tests/kafkatest/services/performance/producer_performance.py",
line 170, in parse_stats
'latency_50th_ms': float(parts[4].split()[0]),
IndexError: list index out of range
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/lib/python3.9/threading.py", line 954, in _bootstrap_inner
self.run()
File "/usr/lib/python3.9/threading.py", line 892, in run
self._target(*self._args, **self._kwargs)
File
"/usr/local/lib/python3.9/dist-packages/ducktape/services/background_thread.py",
line 38, in _protected_worker
self._worker(idx, node)
File
"/opt/kafka-dev/tests/kafkatest/services/performance/producer_performance.py",
line 159, in _worker
raise Exception("Unable to parse aggregate performance statistics on
node %d: %s" % (idx, last))
Exception: Unable to parse aggregate performance statistics on node 1:
2545045 records sent, 505470.7 records/sec (48.21 MB/sec), 788.0 ms avg
latency, 1736.0 ms max latency.
```
--
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]
