kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: Capture stderr in ConsumerPerformanceService.
Date Tue, 20 Oct 2015 00:14:01 GMT
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 <wangguoz@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):


Mime
View raw message