root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: Capture stderr in ConsumerPerformanceService. 

Author: Ewen Cheslack-Postava <me@ewencp.org>

Reviewers: Guozhang Wang

Closes #331 from ewencp/minor-capture-consumer-performance-stderr
This commit is contained in:
Ewen Cheslack-Postava 2015-10-19 17:18:52 -07:00 committed by Guozhang Wang
parent 343db8a7f4
commit 14c128a162
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tests/kafkatest/services/performance/consumer_performance.py
View File

@ -51,6 +51,7 @@ class ConsumerPerformanceService(PerformanceService):
PERSISTENT_ROOT = "/mnt/consumer_performance" PERSISTENT_ROOT = "/mnt/consumer_performance"
LOG_DIR = os.path.join(PERSISTENT_ROOT, "logs") LOG_DIR = os.path.join(PERSISTENT_ROOT, "logs")
STDOUT_CAPTURE = os.path.join(PERSISTENT_ROOT, "consumer_performance.stdout") 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") LOG_FILE = os.path.join(LOG_DIR, "consumer_performance.log")
LOG4J_CONFIG = os.path.join(PERSISTENT_ROOT, "tools-log4j.properties") LOG4J_CONFIG = os.path.join(PERSISTENT_ROOT, "tools-log4j.properties")
CONFIG_FILE = os.path.join(PERSISTENT_ROOT, "consumer.properties") CONFIG_FILE = os.path.join(PERSISTENT_ROOT, "consumer.properties")
@ -59,7 +60,9 @@ class ConsumerPerformanceService(PerformanceService):
"consumer_performance_output": { "consumer_performance_output": {
"path": STDOUT_CAPTURE, "path": STDOUT_CAPTURE,
"collect_default": True}, "collect_default": True},
"consumer_performance_stderr": {
"path": STDERR_CAPTURE,
"collect_default": True},
"consumer_performance_log": { "consumer_performance_log": {
"path": LOG_FILE, "path": LOG_FILE,
"collect_default": True} "collect_default": True}
@ -129,7 +132,8 @@ class ConsumerPerformanceService(PerformanceService):
for key, value in self.settings.items(): for key, value in self.settings.items():
cmd += " %s=%s" % (str(key), str(value)) 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 return cmd
def _worker(self, idx, node): def _worker(self, idx, node):