[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-28 Thread redsanket
Github user redsanket commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-202581682 +1 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-25 Thread knusbaum
Github user knusbaum commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-201345276 +1 Metrics look great. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-24 Thread hustfxj
Github user hustfxj commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-201114123 @redsanket @knusbaum @revans2 can you look it again? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-23 Thread knusbaum
Github user knusbaum commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-200497814 By using gauges we're re-implementing stuff that coda hale does, namely windowed stats. Just take a look at DRPCServer.java, like I mentioned. You can use

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-22 Thread hustfxj
Github user hustfxj commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-200183338 @knusbaum I have remove the JMX, and use Gauge report the stats. I think Gauge is enough. can you look at it again? --- If your project is set up for it, you can

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-21 Thread hustfxj
Github user hustfxj commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-199555267 @knusbaum I also prefer to go to Coda Hale for the stats before, It means we will drop the JMX Mbean. But I agree with you totaly. --- If your project is set up for

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-21 Thread knusbaum
Github user knusbaum commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r56844493 --- Diff: storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java --- @@ -0,0 +1,374 @@ +/** + * Licensed to the Apache Software Foundation

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-21 Thread knusbaum
Github user knusbaum commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-199345559 I'd prefer to go to Coda Hale for the stats like the rest of the daemons do. Take a look at DrpcServer.java for an example. --- If your project is set up for it, you

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-19 Thread knusbaum
Github user knusbaum commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r56557159 --- Diff: storm-core/src/clj/org/apache/storm/pacemaker/pacemaker.clj --- @@ -1,242 +0,0 @@ -;; Licensed to the Apache Software Foundation (ASF) under

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-19 Thread redsanket
Github user redsanket commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r56659070 --- Diff: storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java --- @@ -0,0 +1,372 @@ +/** + * Licensed to the Apache Software Foundation

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-19 Thread hustfxj
Github user hustfxj commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-197645359 @redsanket @abhishekagarwal87 I have addressed your comments, thank you. @redsanket I also am curious where is the jmx related code implemented. But I don't found, so

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-19 Thread redsanket
Github user redsanket commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r56658785 --- Diff: storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java --- @@ -0,0 +1,372 @@ +/** + * Licensed to the Apache Software Foundation

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-19 Thread redsanket
Github user redsanket commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-197508158 Most of the changes look good, just a question about jmx reporter implementation --- If your project is set up for it, you can reply to this email and have your

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-19 Thread redsanket
Github user redsanket commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r56381761 --- Diff: storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java --- @@ -0,0 +1,246 @@ +/** + * Licensed to the Apache Software Foundation

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-19 Thread abhishekagarwal87
Github user abhishekagarwal87 commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-197701113 LGTM --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-19 Thread redsanket
Github user redsanket commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r56383389 --- Diff: storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java --- @@ -0,0 +1,246 @@ +/** + * Licensed to the Apache Software Foundation

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-19 Thread redsanket
Github user redsanket commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r56382441 --- Diff: storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java --- @@ -0,0 +1,246 @@ +/** + * Licensed to the Apache Software Foundation

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-19 Thread redsanket
Github user redsanket commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r56383870 --- Diff: storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java --- @@ -0,0 +1,246 @@ +/** + * Licensed to the Apache Software Foundation

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-19 Thread redsanket
Github user redsanket commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r56366424 --- Diff: storm-core/src/clj/org/apache/storm/daemon/nimbus.clj --- @@ -1353,8 +1353,8 @@ (str "Failed to submit topology. Topology requests

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-19 Thread hustfxj
Github user hustfxj commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-198351433 @redsanket @knusbaum thank you. I have addressed your comments --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-19 Thread redsanket
Github user redsanket commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r56381799 --- Diff: storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java --- @@ -0,0 +1,246 @@ +/** + * Licensed to the Apache Software Foundation

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-18 Thread knusbaum
Github user knusbaum commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-198028339 @hustfxj @redsanket The JMX stuff was in a clojure library `(:require [clojure.java.jmx :as jmx])` It should probably be moved over to Coda Hale since that's what

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-18 Thread redsanket
Github user redsanket commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-198018090 @hustfxj I guess it is more like a plugin to get metrics. I presume the code should be implemented. @knusbaum might be right to answer it. --- If your project is set

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-18 Thread redsanket
Github user redsanket commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r56387356 --- Diff: storm-core/src/clj/org/apache/storm/pacemaker/pacemaker.clj --- @@ -1,242 +0,0 @@ -;; Licensed to the Apache Software Foundation (ASF) under

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-14 Thread hustfxj
Github user hustfxj commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-196393789 Every can help me review this PR. In my perspective , I hope we can accelerate the first phrase job. --- If your project is set up for it, you can reply to this email

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-09 Thread abhishekagarwal87
Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r55520029 --- Diff: storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java --- @@ -0,0 +1,246 @@ +/** + * Licensed to the Apache Software

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-09 Thread hustfxj
Github user hustfxj commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-194280649 @abhishekagarwal87 Thank you. But I hope only it is the same as before for the details. --- If your project is set up for it, you can reply to this email and have

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-09 Thread abhishekagarwal87
Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r55484666 --- Diff: storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java --- @@ -0,0 +1,248 @@ +/** + * Licensed to the Apache Software

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-09 Thread abhishekagarwal87
Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r55484087 --- Diff: storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java --- @@ -0,0 +1,248 @@ +/** + * Licensed to the Apache Software

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-09 Thread abhishekagarwal87
Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/storm/pull/1195#discussion_r55483738 --- Diff: storm-core/src/jvm/org/apache/storm/pacemaker/Pacemaker.java --- @@ -0,0 +1,248 @@ +/** + * Licensed to the Apache Software

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-08 Thread hustfxj
Github user hustfxj commented on the pull request: https://github.com/apache/storm/pull/1195#issuecomment-194168476 when we start up nimbus before starting up pacemaker, the nimbus will die. Because nimbus can't read the workers' heartbeats by "heartbeat-storms". In my opinion, it

[GitHub] storm pull request: [STORM-1611] port org.apache.storm.pacemaker.p...

2016-03-08 Thread hustfxj
GitHub user hustfxj opened a pull request: https://github.com/apache/storm/pull/1195 [STORM-1611] port org.apache.storm.pacemaker.pacemaker to java 1 port pacemaker_test to java; 2 Update all the callings to cluster; 3 remove pacemaker.register about jmx; 4 fix the bug