[GitHub] storm pull request: [STORM-1279] port backtype.storm.daemon.superv...

2016-03-30 Thread longdafeng
Github user longdafeng commented on the pull request: https://github.com/apache/storm/pull/1257#issuecomment-203471618 I have reviewed the PR, it is fine to me except several little problem, but I haven't done any test. Suggest to do integrate test, both local mode and distributed

[GitHub] storm pull request: [STORM-1279] port backtype.storm.daemon.superv...

2016-03-30 Thread longdafeng
Github user longdafeng commented on a diff in the pull request: https://github.com/apache/storm/pull/1257#discussion_r57900100 --- Diff: storm-core/src/jvm/org/apache/storm/daemon/supervisor/SyncSupervisorEvent.java --- @@ -0,0 +1,626 @@ +/** + * Licensed to the Apache

[GitHub] storm pull request: [STORM-1279] port backtype.storm.daemon.superv...

2016-03-30 Thread longdafeng
Github user longdafeng commented on a diff in the pull request: https://github.com/apache/storm/pull/1257#discussion_r57896552 --- Diff: storm-core/src/jvm/org/apache/storm/daemon/supervisor/SyncSupervisorEvent.java --- @@ -0,0 +1,626 @@ +/** + * Licensed to the Apache

[GitHub] storm pull request: [STORM-1279] port backtype.storm.daemon.superv...

2016-03-30 Thread longdafeng
Github user longdafeng commented on a diff in the pull request: https://github.com/apache/storm/pull/1257#discussion_r57887620 --- Diff: storm-core/src/jvm/org/apache/storm/daemon/supervisor/SyncSupervisorEvent.java --- @@ -0,0 +1,626 @@ +/** + * Licensed to the Apache

[GitHub] storm pull request: [STORM-1279] port backtype.storm.daemon.superv...

2016-03-30 Thread longdafeng
Github user longdafeng commented on a diff in the pull request: https://github.com/apache/storm/pull/1257#discussion_r57883592 --- Diff: storm-core/src/jvm/org/apache/storm/daemon/supervisor/timer/SupervisorHealthCheck.java --- @@ -0,0 +1,62 @@ +/** + * Licensed

[GitHub] storm pull request: [STORM-1279] port backtype.storm.daemon.superv...

2016-03-30 Thread longdafeng
Github user longdafeng commented on a diff in the pull request: https://github.com/apache/storm/pull/1257#discussion_r57880994 --- Diff: storm-core/src/jvm/org/apache/storm/daemon/supervisor/timer/SupervisorHeartbeat.java --- @@ -0,0 +1,87 @@ +/** + * Licensed

[GitHub] storm pull request: [STORM-1279] port backtype.storm.daemon.superv...

2016-03-30 Thread longdafeng
Github user longdafeng commented on a diff in the pull request: https://github.com/apache/storm/pull/1257#discussion_r57880519 --- Diff: storm-core/src/jvm/org/apache/storm/daemon/supervisor/SupervisorUtils.java --- @@ -0,0 +1,271 @@ +/** + * Licensed to the Apache

[GitHub] storm pull request: [STORM-1279] port backtype.storm.daemon.superv...

2016-03-30 Thread longdafeng
Github user longdafeng commented on a diff in the pull request: https://github.com/apache/storm/pull/1257#discussion_r57879928 --- Diff: storm-core/src/jvm/org/apache/storm/daemon/supervisor/StandaloneSupervisor.java --- @@ -0,0 +1,83 @@ +/** + * Licensed to the Apache

[GitHub] storm pull request: [STORM-1279] port backtype.storm.daemon.superv...

2016-03-30 Thread longdafeng
Github user longdafeng commented on a diff in the pull request: https://github.com/apache/storm/pull/1257#discussion_r57870832 --- Diff: storm-core/src/jvm/org/apache/storm/daemon/supervisor/DefaultUncaughtExceptionHandler.java --- @@ -0,0 +1,31 @@ +/** + * Licensed

[GitHub] storm pull request: [STORM-1245] port backtype.storm.daemon.acker ...

2016-02-25 Thread longdafeng
Github user longdafeng commented on a diff in the pull request: https://github.com/apache/storm/pull/1069#discussion_r54083889 --- Diff: storm-core/src/jvm/org/apache/storm/daemon/Acker.java --- @@ -0,0 +1,127 @@ +/** + * Licensed to the Apache Software Foundation (ASF

[GitHub] storm pull request: [STORM-1245] port backtype.storm.daemon.acker ...

2016-02-22 Thread longdafeng
Github user longdafeng commented on the pull request: https://github.com/apache/storm/pull/1069#issuecomment-187230721 +1, The acker logic is correct, come from JStorm. In JStorm, it handle two more case: Acker.ACKER_INIT_STREAM_ID's tuple is after

[GitHub] storm pull request: [STORM-1243] port HealthCheck to java

2016-02-18 Thread longdafeng
Github user longdafeng commented on the pull request: https://github.com/apache/storm/pull/#issuecomment-185633860 +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-1553] port event.clj to java

2016-02-18 Thread longdafeng
Github user longdafeng commented on the pull request: https://github.com/apache/storm/pull/1110#issuecomment-185631768 +1, looks good --- 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

[GitHub] storm pull request: [STORM-1262] port dev_zookeeper.clj to java

2016-02-16 Thread longdafeng
Github user longdafeng commented on the pull request: https://github.com/apache/storm/pull/1113#issuecomment-184983036 +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: MINOR: Use /usr/bin/env to find bash

2015-11-19 Thread longdafeng
Github user longdafeng commented on the pull request: https://github.com/apache/storm/pull/892#issuecomment-158033245 +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

Re: [DISCUSS] 1.0 Release (was Re: [DISCUSS] Initial 0.11.0 Release)

2015-11-18 Thread 封仲淹(纪君祥LongdaFeng)
+1 as well. (1) What we have been calling “0.11.0” will become the Storm 1.0  release.[Longda] Agree.  we almost stop developing new feature after 0.11, so  0.11 is one big version of clojure core, I prefer we give it one big milestone  number 1.0 to this version. In fact, this version will

[GitHub] storm pull request: STORM-904: Move bin/storm command line to java...

2015-11-18 Thread longdafeng
Github user longdafeng commented on the pull request: https://github.com/apache/storm/pull/662#issuecomment-157686065 @priyank5485 I don't prefer switch storm.py from python to java. Because I often add debug point in the storm.py, it is very easy to debug in online system

[GitHub] storm pull request: STORM-1155: Supervisor recurring health checks

2015-11-11 Thread longdafeng
Github user longdafeng commented on the pull request: https://github.com/apache/storm/pull/849#issuecomment-155701669 +1 sorry for late response --- 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

Re: [Discusson] Storm System Tests

2015-11-05 Thread 封仲淹(纪君祥LongdaFeng)
+1 By the way, Tong(王桐) can work for this. Tong is responsible for the automatically daily JStorm test, the only problem is that the automatically daily JStorm test is basing on Alibaba testing framework. Some of the components can't run on outside. But we can share the test cases firstly. Then

[GitHub] storm pull request: STORM-1155: Supervisor recurring health checks

2015-11-04 Thread longdafeng
Github user longdafeng commented on the pull request: https://github.com/apache/storm/pull/849#issuecomment-153917289 the code is fine to me, but this is the first step to do health check: (1) where put the script, we had better put the script under $STORM_HOME/healthcheck

[GitHub] storm pull request: STORM-553:add eclipse java formatter file for ...

2015-04-08 Thread longdafeng
Github user longdafeng commented on the pull request: https://github.com/apache/storm/pull/478#issuecomment-90834098 why indentation.size and tabulation.size are 2, normally they are 4. --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] storm pull request: [STORM-712] Storm daemons shutdown if OutOfMem...

2015-03-26 Thread longdafeng
Github user longdafeng commented on a diff in the pull request: https://github.com/apache/storm/pull/468#discussion_r27273285 --- Diff: storm-core/src/jvm/backtype/storm/utils/Utils.java --- @@ -533,4 +533,16 @@ private static SerializationDelegate getSerializationDelegate(Map

[GitHub] storm pull request: Storm-166: Nimbus HA design doc and implementa...

2015-03-23 Thread longdafeng
Github user longdafeng commented on the pull request: https://github.com/apache/storm/pull/354#issuecomment-85033376 @ptgoetz @revans2 @Parth-Brahmbhatt, Sorry for late discuss the HA desgin. Strongly recommend using JStorm's Nimbus HA Design. It is pretty stable

[GitHub] storm pull request: Storm-166: Nimbus HA design doc and implementa...

2015-03-23 Thread longdafeng
Github user longdafeng commented on the pull request: https://github.com/apache/storm/pull/354#issuecomment-85341944 @Parth-Brahmbhatt , I don't suggest using org.apache.curator.framework.recipes.leader In fact, We had implemented HA