From 14c128a162a7540f22e78a2e4bab6f20662b49ce Mon Sep 17 00:00:00 2001 From: Ewen Cheslack-Postava Date: Mon, 19 Oct 2015 17:18:52 -0700 Subject: [PATCH] MINOR: Capture stderr in ConsumerPerformanceService. Author: Ewen Cheslack-Postava Reviewers: Guozhang Wang Closes #331 from ewencp/minor-capture-consumer-performance-stderr --- .../services/performance/consumer_performance.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/tests/kafkatest/services/performance/consumer_performance.py b/tests/kafkatest/services/performance/consumer_performance.py index b8eab224717..053059b3b59 100644 --- a/tests/kafkatest/services/performance/consumer_performance.py +++ b/tests/kafkatest/services/performance/consumer_performance.py @@ -51,6 +51,7 @@ class ConsumerPerformanceService(PerformanceService): PERSISTENT_ROOT = "/mnt/consumer_performance" LOG_DIR = os.path.join(PERSISTENT_ROOT, "logs") STDOUT_CAPTURE = os.path.join(PERSISTENT_ROOT, "consumer_performance.stdout") + STDERR_CAPTURE = os.path.join(PERSISTENT_ROOT, "consumer_performance.stderr") LOG_FILE = os.path.join(LOG_DIR, "consumer_performance.log") LOG4J_CONFIG = os.path.join(PERSISTENT_ROOT, "tools-log4j.properties") CONFIG_FILE = os.path.join(PERSISTENT_ROOT, "consumer.properties") @@ -59,7 +60,9 @@ class ConsumerPerformanceService(PerformanceService): "consumer_performance_output": { "path": STDOUT_CAPTURE, "collect_default": True}, - + "consumer_performance_stderr": { + "path": STDERR_CAPTURE, + "collect_default": True}, "consumer_performance_log": { "path": LOG_FILE, "collect_default": True} @@ -129,7 +132,8 @@ class ConsumerPerformanceService(PerformanceService): for key, value in self.settings.items(): cmd += " %s=%s" % (str(key), str(value)) - cmd += " | tee %s" % ConsumerPerformanceService.STDOUT_CAPTURE + cmd += " 2>> %(stderr)s | tee -a %(stdout)s" % {'stdout': ConsumerPerformanceService.STDOUT_CAPTURE, + 'stderr': ConsumerPerformanceService.STDERR_CAPTURE} return cmd def _worker(self, idx, node):