[jira] [Commented] (STORM-1277) port backtype.storm.daemon.executor to java

[ https://issues.apache.org/jira/browse/STORM-1277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15367242#comment-15367242 ] ASF GitHub Bot commented on STORM-1277: --- Github user unsleepy22 commented on the issue:

[GitHub] storm issue #1445: [STORM-1277] port backtype.storm.daemon.executor to java

Github user unsleepy22 commented on the issue: https://github.com/apache/storm/pull/1445 @hustfxj could you take a look? --- 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

[jira] [Commented] (STORM-1281) port backtype.storm.testing to java

[ https://issues.apache.org/jira/browse/STORM-1281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15367159#comment-15367159 ] Abhishek Agarwal commented on STORM-1281: - [~kabhwan] It depends on components which haven't been

[jira] [Commented] (STORM-1910) One topology can't use hdfs spout to read from two locations

[ https://issues.apache.org/jira/browse/STORM-1910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15367096#comment-15367096 ] Roshan Naik commented on STORM-1910: WRT Pt# 2 in the description, we cannot check for valid HDFS path

[jira] [Updated] (STORM-1952) Keeping topology code for supervisor until topology got killed

[ https://issues.apache.org/jira/browse/STORM-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1952: Description: It's based on review comment from [~sriharsha].

[jira] [Commented] (STORM-1934) Race condition between sync-supervisor and sync-processes raises several strange issues

[ https://issues.apache.org/jira/browse/STORM-1934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15367089#comment-15367089 ] ASF GitHub Bot commented on STORM-1934: --- Github user HeartSaVioR commented on a diff in the pull

[GitHub] storm pull request #1528: STORM-1934 Fix race condition between sync-supervi...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/1528#discussion_r70016445 --- Diff: storm-core/src/clj/org/apache/storm/daemon/supervisor.clj --- @@ -425,6 +433,13 @@ ". State: " state ", Heartbeat: "

[jira] [Created] (STORM-1952) Keeping topology code for supervisor until topology got killed

Jungtaek Lim created STORM-1952: --- Summary: Keeping topology code for supervisor until topology got killed Key: STORM-1952 URL: https://issues.apache.org/jira/browse/STORM-1952 Project: Apache Storm

[jira] [Commented] (STORM-1281) port backtype.storm.testing to java

[ https://issues.apache.org/jira/browse/STORM-1281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366852#comment-15366852 ] Jungtaek Lim commented on STORM-1281: - [~abhishek.agarwal] Do you have any update on this? Lots of

[jira] [Comment Edited] (STORM-1281) port backtype.storm.testing to java

[ https://issues.apache.org/jira/browse/STORM-1281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366852#comment-15366852 ] Jungtaek Lim edited comment on STORM-1281 at 7/7/16 10:00 PM: --

[jira] [Commented] (STORM-1916) Add ability for worker-first classpath

[ https://issues.apache.org/jira/browse/STORM-1916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366701#comment-15366701 ] ASF GitHub Bot commented on STORM-1916: --- Github user knusbaum commented on a diff in the pull

[GitHub] storm pull request #1507: STORM-1916: Add ability for worker-first classpath

Github user knusbaum commented on a diff in the pull request: https://github.com/apache/storm/pull/1507#discussion_r69977876 --- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java --- @@ -2092,6 +2092,11 @@ public static String addToClasspath(String classpath,

[jira] [Resolved] (STORM-1238) port backtype.storm.security.auth.ThriftServer-test to java

[ https://issues.apache.org/jira/browse/STORM-1238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1238. - Resolution: Fixed Fix Version/s: 2.0.0 Thanks [~abhishek.agarwal], I merged into master.

[jira] [Resolved] (STORM-1237) port backtype.storm.security.auth.ThriftClient-test to java

[ https://issues.apache.org/jira/browse/STORM-1237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1237. - Resolution: Fixed Fix Version/s: 2.0.0 Thanks [~abhishek.agarwal], I merged into master.

[jira] [Resolved] (STORM-1236) port backtype.storm.security.auth.SaslTransportPlugin-test to java

[ https://issues.apache.org/jira/browse/STORM-1236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1236. - Resolution: Fixed Fix Version/s: 2.0.0 Thanks [~abhishek.agarwal], I merged into master.

[jira] [Resolved] (STORM-1249) port backtype.storm.security.serialization.BlowfishTupleSerializer-test to java

[ https://issues.apache.org/jira/browse/STORM-1249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1249. - Resolution: Fixed Fix Version/s: 2.0.0 Thanks [~abhishek.agarwal], I merged into master.

[jira] [Resolved] (STORM-1235) port backtype.storm.security.auth.ReqContext-test to java

[ https://issues.apache.org/jira/browse/STORM-1235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1235. - Resolution: Fixed Fix Version/s: 2.0.0 Thanks [~abhishek.agarwal], I merged into master.

[jira] [Commented] (STORM-1235) port backtype.storm.security.auth.ReqContext-test to java

[ https://issues.apache.org/jira/browse/STORM-1235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366189#comment-15366189 ] ASF GitHub Bot commented on STORM-1235: --- Github user asfgit closed the pull request at:

[GitHub] storm pull request #1200: Tests - STORM-1235, STORM-1236, STORM-1237, STORM-...

Github user asfgit closed the pull request at: https://github.com/apache/storm/pull/1200 --- 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 and wishes so, or if the feature is

[jira] [Commented] (STORM-1235) port backtype.storm.security.auth.ReqContext-test to java

[ https://issues.apache.org/jira/browse/STORM-1235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366170#comment-15366170 ] ASF GitHub Bot commented on STORM-1235: --- Github user HeartSaVioR commented on the issue:

[GitHub] storm issue #1200: Tests - STORM-1235, STORM-1236, STORM-1237, STORM-1238, S...

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1200 +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 and wishes so, or if the

[jira] [Commented] (STORM-1235) port backtype.storm.security.auth.ReqContext-test to java

[ https://issues.apache.org/jira/browse/STORM-1235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366077#comment-15366077 ] ASF GitHub Bot commented on STORM-1235: --- Github user hustfxj commented on the issue:

[GitHub] storm issue #1200: Tests - STORM-1235, STORM-1236, STORM-1237, STORM-1238, S...

Github user hustfxj commented on the issue: https://github.com/apache/storm/pull/1200 Thank you @abhishekagarwal87 +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

[jira] [Commented] (STORM-1833) Add simple equi-join support in storm-sql standalone mode

[ https://issues.apache.org/jira/browse/STORM-1833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365942#comment-15365942 ] ASF GitHub Bot commented on STORM-1833: --- Github user arunmahadevan commented on the issue:

[GitHub] storm issue #1413: [STORM-1833] Simple equi-join in storm-sql standalone mod...

Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1413 @harshach @haohui could you please take a look ? --- 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

Set Number of supervisors

Hi all, I want to run more than one supervisor. I just created two process: storm supervisor, but what I can see in the UI only one supervisor!So Anyone can tell how can we specify the number supervisors? The second question: from supervisor machines when I access UI by the IP address of

[jira] [Created] (STORM-1951) Move example topologies of modules into examples directory

Abhishek Agarwal created STORM-1951: --- Summary: Move example topologies of modules into examples directory Key: STORM-1951 URL: https://issues.apache.org/jira/browse/STORM-1951 Project: Apache Storm

[jira] [Commented] (STORM-1235) port backtype.storm.security.auth.ReqContext-test to java

[ https://issues.apache.org/jira/browse/STORM-1235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365890#comment-15365890 ] Abhishek Agarwal commented on STORM-1235: - [~Johnbaba] can you review this PR? > port

Re: [DISCUSS] Maintaining example topologies for external components

Alright. The majority seems to be in agreement over submodules inside examples. I will do the clean up of existing modules. Post that, we can follow the same rule for new modules. On Thu, Jun 30, 2016 at 8:32 PM, Cody Innowhere wrote: > We can have examples in perspective

[jira] [Commented] (STORM-1945) Internal Server Error shown on topology page for topology using KafkaSpout

[ https://issues.apache.org/jira/browse/STORM-1945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365877#comment-15365877 ] ASF GitHub Bot commented on STORM-1945: --- Github user HeartSaVioR commented on the issue:

[GitHub] storm issue #1541: STORM-1945 Fix NPE bugs on topology spout lag for storm-k...

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1541 It would be better for changing JSON response to file a new issue and make it out of scope for this PR, since [STORM-1945](https://issues.apache.org/jira/browse/STORM-1945) is a bugfix which is

[jira] [Created] (STORM-1950) Change response json of "Topology Lag" REST API to keyed by spoutId, topic, partition

Jungtaek Lim created STORM-1950: --- Summary: Change response json of "Topology Lag" REST API to keyed by spoutId, topic, partition Key: STORM-1950 URL: https://issues.apache.org/jira/browse/STORM-1950

Re: Nimbus runnig for short time only

There is a problem with your ZooKeeper server(s). That is something Nimbus relies upon, so you must get that working before you should worry about Nimbus. - Erik On Thursday, July 7, 2016, Walid Aljoby wrote: > Hi all, > > I have an issue when start running storm

Nimbus runnig for short time only

Hi all, I have an issue when start running storm nimbus. It runs only for short time then disappear. Also no reply for this command: echo stat | nc zkserver1 2181 This is snapshot from nimbus log file: java.lang.RuntimeException:

[jira] [Commented] (STORM-1949) Backpressure can cause spout to stop emitting and stall topology

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365705#comment-15365705 ] Jungtaek Lim commented on STORM-1949: - And I think we need to include section to UI representing

[jira] [Commented] (STORM-1939) Frequent InterruptedException raised by ShellBoltMessageQueue.poll

[ https://issues.apache.org/jira/browse/STORM-1939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365701#comment-15365701 ] ASF GitHub Bot commented on STORM-1939: --- Github user HeartSaVioR commented on a diff in the pull

[jira] [Commented] (STORM-1945) Internal Server Error shown on topology page for topology using KafkaSpout

[ https://issues.apache.org/jira/browse/STORM-1945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365698#comment-15365698 ] ASF GitHub Bot commented on STORM-1945: --- Github user HeartSaVioR commented on the issue:

[GitHub] storm issue #1541: STORM-1945 Fix NPE bugs on topology spout lag for storm-k...

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1541 @harshach I guess you mean this: ``` [ { "spoutId":"spout", "spoutType":"KAFKA", "spoutLagResult":{ "topic":{

[jira] [Commented] (STORM-1949) Backpressure can cause spout to stop emitting and stall topology

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365694#comment-15365694 ] Abhishek Agarwal commented on STORM-1949: - can we also have a thread stack taken after the

[jira] [Commented] (STORM-1939) Frequent InterruptedException raised by ShellBoltMessageQueue.poll

[ https://issues.apache.org/jira/browse/STORM-1939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365685#comment-15365685 ] ASF GitHub Bot commented on STORM-1939: --- Github user abhishekagarwal87 commented on a diff in the

[GitHub] storm pull request #1543: STORM-1939 Ignore InterruptedException on ShellBol...

Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/storm/pull/1543#discussion_r69857393 --- Diff: storm-core/src/jvm/org/apache/storm/task/ShellBolt.java --- @@ -158,8 +158,8 @@ public void execute(Tuple input) {

[GitHub] storm pull request #1541: STORM-1945 Fix NPE bugs on topology spout lag for ...

Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/storm/pull/1541#discussion_r69857098 --- Diff: storm-dist/binary/src/main/assembly/binary.xml --- @@ -340,10 +340,10 @@ -

[GitHub] storm issue #1544: ConcurrentModificationExceptions in WindowedBoltExecutorT...

Github user abhishekagarwal87 commented on the issue: https://github.com/apache/storm/pull/1544 No there was another error in the same test ``` classname: org.apache.storm.topology.WindowedBoltExecutorTest / testname: testExecuteWithLateTupleStream

[GitHub] storm issue #1544: ConcurrentModificationExceptions in WindowedBoltExecutorT...

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1544 @abhishekagarwal87 Is it a fix for this random failure? ``` classname: org.apache.storm.topology.WindowedBoltExecutorTest / testname: testExecuteWithLateTupleStream

[jira] [Commented] (STORM-1934) Race condition between sync-supervisor and sync-processes raises several strange issues

[ https://issues.apache.org/jira/browse/STORM-1934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365675#comment-15365675 ] ASF GitHub Bot commented on STORM-1934: --- Github user harshach commented on the issue:

[GitHub] storm pull request #1541: STORM-1945 Fix NPE bugs on topology spout lag for ...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/1541#discussion_r69855945 --- Diff: storm-dist/binary/src/main/assembly/binary.xml --- @@ -340,10 +340,10 @@ -

[jira] [Commented] (STORM-1945) Internal Server Error shown on topology page for topology using KafkaSpout

[ https://issues.apache.org/jira/browse/STORM-1945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365674#comment-15365674 ] ASF GitHub Bot commented on STORM-1945: --- Github user abhishekagarwal87 commented on a diff in the

[GitHub] storm pull request #1541: STORM-1945 Fix NPE bugs on topology spout lag for ...

Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/storm/pull/1541#discussion_r69855772 --- Diff: storm-dist/binary/src/main/assembly/binary.xml --- @@ -340,10 +340,10 @@ -