kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject git commit: kafka-1567; Metric memory leaking after closing the clients; patched by Jiangjie Qin; reviewed by Guozhang Wang and Jun Rao
Date Fri, 15 Aug 2014 00:39:50 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk aa70a7d02 -> a552d4b74


kafka-1567; Metric memory leaking after closing the clients; patched by Jiangjie Qin; reviewed
by Guozhang Wang and Jun Rao


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a552d4b7
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/a552d4b7
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/a552d4b7

Branch: refs/heads/trunk
Commit: a552d4b743c44db0adcb58273b92301b2a4df38b
Parents: aa70a7d
Author: Manikumar Reddy <manikumar.reddy@gmail.com>
Authored: Wed Aug 13 13:08:57 2014 -0700
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Thu Aug 14 17:39:46 2014 -0700

----------------------------------------------------------------------
 kafka-patch-review.py | 26 ++++++++++++++++++++++----
 1 file changed, 22 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/a552d4b7/kafka-patch-review.py
----------------------------------------------------------------------
diff --git a/kafka-patch-review.py b/kafka-patch-review.py
index 89afc84..2ca0174 100644
--- a/kafka-patch-review.py
+++ b/kafka-patch-review.py
@@ -9,14 +9,19 @@ import tempfile
 import commands
 from jira.client import JIRA
 
-def get_jira():
-  options = {
-    'server': 'https://issues.apache.org/jira'
-  }
+def get_jira_config():
   # read the config file
   home=jira_home=os.getenv('HOME')
   home=home.rstrip('/')
   jira_config = dict(line.strip().split('=') for line in open(home + '/jira.ini'))
+  return jira_config
+
+def get_jira():
+  options = {
+    'server': 'https://issues.apache.org/jira'
+  }
+
+  jira_config = get_jira_config()
   jira = JIRA(options,basic_auth=(jira_config['user'], jira_config['password']))
   return jira
 
@@ -134,5 +139,18 @@ def main():
   comment = comment + rb_url + ' against branch ' + opt.branch
   jira.add_comment(opt.jira, comment)
 
+  #update the JIRA status to PATCH AVAILABLE
+  transitions = jira.transitions(issue)
+  transitionsMap ={}
+  
+  for t in transitions:
+    transitionsMap[t['name']] = t['id']
+
+  jira_config = get_jira_config()
+
+  if('Submit Patch' in transitionsMap):
+     jira.transition_issue(issue, transitionsMap['Submit Patch'] , assignee={'name': jira_config['user']}
)
+
+
 if __name__ == '__main__':
   sys.exit(main())


Mime
View raw message