You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2015/10/20 02:14:01 UTC
kafka git commit: MINOR: Capture stderr in ConsumerPerformanceService.
Repository: kafka
Updated Branches:
refs/heads/trunk 343db8a7f -> 14c128a16
MINOR: Capture stderr in ConsumerPerformanceService.
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Reviewers: Guozhang Wang
Closes #331 from ewencp/minor-capture-consumer-performance-stderr
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/14c128a1
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/14c128a1
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/14c128a1
Branch: refs/heads/trunk
Commit: 14c128a162a7540f22e78a2e4bab6f20662b49ce
Parents: 343db8a
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Authored: Mon Oct 19 17:18:52 2015 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Mon Oct 19 17:18:52 2015 -0700
----------------------------------------------------------------------
tests/kafkatest/services/performance/consumer_performance.py | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/14c128a1/tests/kafkatest/services/performance/consumer_performance.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/services/performance/consumer_performance.py b/tests/kafkatest/services/performance/consumer_performance.py
index b8eab22..053059b 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):