You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ma...@apache.org on 2019/05/22 13:43:30 UTC
[kafka] branch trunk updated: MINOR: Use `jps` cmd to find out the
pid of TransactionalMessageCopier
This is an automated email from the ASF dual-hosted git repository.
manikumar pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 5ca6a2e MINOR: Use `jps` cmd to find out the pid of TransactionalMessageCopier
5ca6a2e is described below
commit 5ca6a2ee94c71092083c93a384faa46c9e2ade97
Author: Manikumar Reddy <ma...@gmail.com>
AuthorDate: Wed May 22 19:12:55 2019 +0530
MINOR: Use `jps` cmd to find out the pid of TransactionalMessageCopier
Author: Manikumar Reddy <ma...@gmail.com>
Reviewers: Rajini Sivaram <ra...@googlemail.com>
Closes #6787 from omkreddy/transaction_test
---
tests/kafkatest/services/transactional_message_copier.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/tests/kafkatest/services/transactional_message_copier.py b/tests/kafkatest/services/transactional_message_copier.py
index 7e96a2c..53fffa4 100644
--- a/tests/kafkatest/services/transactional_message_copier.py
+++ b/tests/kafkatest/services/transactional_message_copier.py
@@ -135,7 +135,7 @@ class TransactionalMessageCopier(KafkaPathResolverMixin, BackgroundThreadService
def pids(self, node):
try:
- cmd = "ps ax | grep -i TransactionalMessageCopier | grep java | grep -v grep | awk '{print $1}'"
+ cmd = "jps | grep -i TransactionalMessageCopier | awk '{print $1}'"
pid_arr = [pid for pid in node.account.ssh_capture(cmd, allow_fail=True, callback=int)]
return pid_arr
except (RemoteCommandError, ValueError) as e: