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 <[email protected]> Authored: Wed Aug 13 13:08:57 2014 -0700 Committer: Neha Narkhede <[email protected]> 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())
