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

2016-03-14 Thread abhishekagarwal87
Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/storm/pull/1184#discussion_r55963334 --- Diff: storm-core/src/jvm/org/apache/storm/daemon/supervisor/SyncProcessEvent.java --- @@ -0,0 +1,672 @@ +/** + * Licensed to the Apache

[jira] [Commented] (STORM-1279) port backtype.storm.daemon.supervisor to java

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192858#comment-15192858 ] ASF GitHub Bot commented on STORM-1279: --- Github user abhishekagarwal87 commented on

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

2016-03-14 Thread abhishekagarwal87
Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/storm/pull/1184#discussion_r55963987 --- Diff: storm-core/src/jvm/org/apache/storm/daemon/supervisor/SyncProcessEvent.java --- @@ -0,0 +1,672 @@ +/** + * Licensed to the Apache

[jira] [Commented] (STORM-1279) port backtype.storm.daemon.supervisor to java

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192863#comment-15192863 ] ASF GitHub Bot commented on STORM-1279: --- Github user abhishekagarwal87 commented on

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

2016-03-14 Thread abhishekagarwal87
Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/storm/pull/1184#discussion_r55964084 --- Diff: storm-core/src/jvm/org/apache/storm/daemon/supervisor/SyncProcessEvent.java --- @@ -0,0 +1,672 @@ +/** + * Licensed to the Apache

[jira] [Commented] (STORM-1279) port backtype.storm.daemon.supervisor to java

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192864#comment-15192864 ] ASF GitHub Bot commented on STORM-1279: --- Github user abhishekagarwal87 commented on

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

2016-03-14 Thread abhishekagarwal87
Github user abhishekagarwal87 commented on a diff in the pull request: https://github.com/apache/storm/pull/1184#discussion_r55965454 --- Diff: storm-core/src/jvm/org/apache/storm/daemon/supervisor/SyncSupervisorEvent.java --- @@ -0,0 +1,631 @@ +/** + * Licensed to the Apa

[jira] [Commented] (STORM-1279) port backtype.storm.daemon.supervisor to java

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192876#comment-15192876 ] ASF GitHub Bot commented on STORM-1279: --- Github user abhishekagarwal87 commented on

[GitHub] storm pull request: STORM-1464: Support multiple file outputs

2016-03-14 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1044#discussion_r55965801 --- Diff: external/storm-hdfs/README.md --- @@ -240,6 +240,23 @@ If you are using Trident and sequence files you can do something like this:

[GitHub] storm pull request: STORM-1464: Support multiple file outputs

2016-03-14 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1044#discussion_r55965826 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/AbstractHdfsBolt.java --- @@ -52,9 +54,10 @@ * Half of the default Con

[jira] [Commented] (STORM-1464) storm-hdfs should support writing to multiple files

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192881#comment-15192881 ] ASF GitHub Bot commented on STORM-1464: --- Github user arunmahadevan commented on a di

[jira] [Commented] (STORM-1464) storm-hdfs should support writing to multiple files

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192883#comment-15192883 ] ASF GitHub Bot commented on STORM-1464: --- Github user arunmahadevan commented on a di

[GitHub] storm pull request: STORM-1464: Support multiple file outputs

2016-03-14 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1044#discussion_r55965855 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/AbstractHdfsBolt.java --- @@ -198,22 +194,62 @@ public final void execute(Tuple

[GitHub] storm pull request: STORM-1464: Support multiple file outputs

2016-03-14 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1044#discussion_r55965843 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/AbstractHdfsBolt.java --- @@ -145,13 +134,20 @@ public final void execute(Tuple

[jira] [Commented] (STORM-1464) storm-hdfs should support writing to multiple files

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192882#comment-15192882 ] ASF GitHub Bot commented on STORM-1464: --- Github user arunmahadevan commented on a di

[GitHub] storm pull request: STORM-1464: Support multiple file outputs

2016-03-14 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1044#discussion_r55965890 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/AbstractHdfsBolt.java --- @@ -198,22 +194,62 @@ public final void execute(Tuple

[GitHub] storm pull request: STORM-1464: Support multiple file outputs

2016-03-14 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1044#discussion_r55965901 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/AbstractHdfsBolt.java --- @@ -198,22 +194,62 @@ public final void execute(Tuple

[GitHub] storm pull request: STORM-1464: Support multiple file outputs

2016-03-14 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1044#discussion_r55965923 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/AbstractHdfsBolt.java --- @@ -223,29 +259,57 @@ public final void execute(Tuple

[GitHub] storm pull request: STORM-1464: Support multiple file outputs

2016-03-14 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1044#discussion_r55965933 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/AbstractHdfsBolt.java --- @@ -223,29 +259,57 @@ public final void execute(Tuple

[jira] [Commented] (STORM-1464) storm-hdfs should support writing to multiple files

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192884#comment-15192884 ] ASF GitHub Bot commented on STORM-1464: --- Github user arunmahadevan commented on a di

[jira] [Commented] (STORM-1464) storm-hdfs should support writing to multiple files

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192886#comment-15192886 ] ASF GitHub Bot commented on STORM-1464: --- Github user arunmahadevan commented on a di

[jira] [Commented] (STORM-1464) storm-hdfs should support writing to multiple files

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192888#comment-15192888 ] ASF GitHub Bot commented on STORM-1464: --- Github user arunmahadevan commented on a di

[jira] [Commented] (STORM-1464) storm-hdfs should support writing to multiple files

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192887#comment-15192887 ] ASF GitHub Bot commented on STORM-1464: --- Github user arunmahadevan commented on a di

[jira] [Commented] (STORM-1464) storm-hdfs should support writing to multiple files

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192885#comment-15192885 ] ASF GitHub Bot commented on STORM-1464: --- Github user arunmahadevan commented on a di

[GitHub] storm pull request: STORM-1464: Support multiple file outputs

2016-03-14 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1044#issuecomment-196194151 @dossett @harshach the changes looks good overall, but I have a few questions/comments and once those are addressed I will review it again. --- If your project is

[jira] [Commented] (STORM-1464) storm-hdfs should support writing to multiple files

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192889#comment-15192889 ] ASF GitHub Bot commented on STORM-1464: --- Github user arunmahadevan commented on the

[GitHub] storm pull request: STORM-956: When the execute() or nextTuple() h...

2016-03-14 Thread hustfxj
Github user hustfxj commented on the pull request: https://github.com/apache/storm/pull/1209#issuecomment-196213692 It looks to good. I also hope we should see this done through both the metrics system and through writing an error into zookeeper that would show up on the UI for the c

[jira] [Commented] (STORM-956) When the execute() or nextTuple() hang on external resources, stop the Worker's heartbeat

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192943#comment-15192943 ] ASF GitHub Bot commented on STORM-956: -- Github user hustfxj commented on the pull requ

[GitHub] storm pull request: STORM-956: When the execute() or nextTuple() h...

2016-03-14 Thread hustfxj
Github user hustfxj commented on the pull request: https://github.com/apache/storm/pull/1209#issuecomment-196220384 Spout itself emits messages by SpoutOutputCollector 's emit(). If lots of messages failed, then acker will trigger SpoutOutputCollector emits those failed messages. It

[jira] [Commented] (STORM-956) When the execute() or nextTuple() hang on external resources, stop the Worker's heartbeat

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15192961#comment-15192961 ] ASF GitHub Bot commented on STORM-956: -- Github user hustfxj commented on the pull requ

[jira] [Resolved] (STORM-1618) Add the option of passing config directory apart from the file

2016-03-14 Thread Abhishek Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhishek Agarwal resolved STORM-1618. - Resolution: Fixed Fix Version/s: 2.0.0 > Add the option of passing config directory

[GitHub] storm pull request: [STORM-1252] port backtype.storm.stats to java

2016-03-14 Thread unsleepy22
Github user unsleepy22 commented on the pull request: https://github.com/apache/storm/pull/1147#issuecomment-196277268 @revans2 any update on this? --- 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

[jira] [Commented] (STORM-1252) port backtype.storm.stats to java

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193149#comment-15193149 ] ASF GitHub Bot commented on STORM-1252: --- Github user unsleepy22 commented on the pul

[GitHub] storm pull request: STORM-676 Trident implementation for sliding a...

2016-03-14 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1072#discussion_r55989920 --- Diff: storm-core/src/jvm/org/apache/storm/trident/Stream.java --- @@ -565,19 +578,169 @@ public Stream aggregate(Fields inputFields, ReducerAggregat

[jira] [Commented] (STORM-676) Storm Trident support for sliding/tumbling windows

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193154#comment-15193154 ] ASF GitHub Bot commented on STORM-676: -- Github user arunmahadevan commented on a diff

[GitHub] storm pull request: STORM-676 Trident implementation for sliding a...

2016-03-14 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1072#issuecomment-196279990 Haven't gone through the code in great detail, but when I ran a simple topology with a tumbling time window of 3 secs, - If the spout emits a batch and sle

[jira] [Commented] (STORM-676) Storm Trident support for sliding/tumbling windows

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193155#comment-15193155 ] ASF GitHub Bot commented on STORM-676: -- Github user arunmahadevan commented on the pul

[GitHub] storm pull request: [STORM-1615] Update state checkpointing doc wi...

2016-03-14 Thread arunmahadevan
GitHub user arunmahadevan opened a pull request: https://github.com/apache/storm/pull/1210 [STORM-1615] Update state checkpointing doc with the acking behavior You can merge this pull request into a Git repository by running: $ git pull https://github.com/arunmahadevan/storm S

[jira] [Commented] (STORM-1615) Update state checkpointing doc with bolt's acking contract

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193246#comment-15193246 ] ASF GitHub Bot commented on STORM-1615: --- GitHub user arunmahadevan opened a pull req

[jira] [Created] (STORM-1622) Topology jars referring to shaded classes of older version of storm jar cannot be run in Storm 1.0.0

2016-03-14 Thread Abhishek Agarwal (JIRA)
Abhishek Agarwal created STORM-1622: --- Summary: Topology jars referring to shaded classes of older version of storm jar cannot be run in Storm 1.0.0 Key: STORM-1622 URL: https://issues.apache.org/jira/browse/STOR

[jira] [Commented] (STORM-1622) Topology jars referring to shaded classes of older version of storm jar cannot be run in Storm 1.0.0

2016-03-14 Thread Abhishek Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193267#comment-15193267 ] Abhishek Agarwal commented on STORM-1622: - Got this exception while submitting the

[jira] [Commented] (STORM-1622) Topology jars referring to shaded classes of older version of storm jar cannot be run in Storm 1.0.0

2016-03-14 Thread Robert Joseph Evans (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193270#comment-15193270 ] Robert Joseph Evans commented on STORM-1622: Topology jars are not supposed to

[jira] [Created] (STORM-1623) nimbus.clj's minor bug

2016-03-14 Thread John Fang (JIRA)
John Fang created STORM-1623: Summary: nimbus.clj's minor bug Key: STORM-1623 URL: https://issues.apache.org/jira/browse/STORM-1623 Project: Apache Storm Issue Type: Bug Reporter: Joh

[GitHub] storm pull request: fix bug about nimbus.clj

2016-03-14 Thread hustfxj
GitHub user hustfxj opened a pull request: https://github.com/apache/storm/pull/1211 fix bug about nimbus.clj You can merge this pull request into a Git repository by running: $ git pull https://github.com/hustfxj/storm nimbus-bug Alternatively you can review and apply these

[jira] [Commented] (STORM-1623) nimbus.clj's minor bug

2016-03-14 Thread John Fang (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193278#comment-15193278 ] John Fang commented on STORM-1623: -- https://github.com/apache/storm/pull/1211 > nimbus.c

[jira] [Commented] (STORM-1622) Topology jars referring to shaded classes of older version of storm jar cannot be run in Storm 1.0.0

2016-03-14 Thread Robert Joseph Evans (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193289#comment-15193289 ] Robert Joseph Evans commented on STORM-1622: [~abhishek.agarwal], Sorry I gue

[jira] [Created] (STORM-1624) add maven central status in README

2016-03-14 Thread Xin Wang (JIRA)
Xin Wang created STORM-1624: --- Summary: add maven central status in README Key: STORM-1624 URL: https://issues.apache.org/jira/browse/STORM-1624 Project: Apache Storm Issue Type: Improvement

[jira] [Commented] (STORM-1464) storm-hdfs should support writing to multiple files

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193307#comment-15193307 ] ASF GitHub Bot commented on STORM-1464: --- Github user dossett commented on the pull r

[GitHub] storm pull request: STORM-676 Trident implementation for sliding a...

2016-03-14 Thread satishd
Github user satishd commented on the pull request: https://github.com/apache/storm/pull/1072#issuecomment-196317380 @arunmahadevan What is the batch emit interval in your topology configuration? Each triggered result is emitted as part of the nearest batch completed. Trident runs in b

[GitHub] storm pull request: [STORM-1624] add maven central status in READM...

2016-03-14 Thread vesense
GitHub user vesense opened a pull request: https://github.com/apache/storm/pull/1212 [STORM-1624] add maven central status in README You can merge this pull request into a Git repository by running: $ git pull https://github.com/vesense/storm maven-status Alternatively you ca

[jira] [Commented] (STORM-1624) add maven central status in README

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193315#comment-15193315 ] ASF GitHub Bot commented on STORM-1624: --- GitHub user vesense opened a pull request:

[jira] [Commented] (STORM-676) Storm Trident support for sliding/tumbling windows

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193313#comment-15193313 ] ASF GitHub Bot commented on STORM-676: -- Github user satishd commented on the pull requ

[GitHub] storm pull request: STORM-1464: Support multiple file outputs

2016-03-14 Thread dossett
Github user dossett commented on the pull request: https://github.com/apache/storm/pull/1044#issuecomment-196316194 Thanks @arunmahadevan and @harshach. I'll rebase and review feedback this week. --- If your project is set up for it, you can reply to this email and have your reply a

[jira] [Commented] (STORM-1483) add storm-mongodb connector

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193319#comment-15193319 ] ASF GitHub Bot commented on STORM-1483: --- Github user vesense commented on the pull r

[GitHub] storm pull request: [STORM-1483] add storm-mongodb connector

2016-03-14 Thread vesense
Github user vesense commented on the pull request: https://github.com/apache/storm/pull/1038#issuecomment-196319894 ping @harshach --- 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 featur

[GitHub] storm pull request: [STORM-1608] Fix stateful topology acking beha...

2016-03-14 Thread arunmahadevan
Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1190#issuecomment-19633 @revans2 @ptgoetz I think the comments in this PR are addressed, can you take a look and merge ? Also raised https://github.com/apache/storm/pull/1210 for updating

[jira] [Commented] (STORM-1608) Fix stateful topology acking behavior

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193329#comment-15193329 ] ASF GitHub Bot commented on STORM-1608: --- Github user arunmahadevan commented on the

[jira] [Created] (STORM-1625) guava dependency is being shipped inside storm distribution

2016-03-14 Thread Abhishek Agarwal (JIRA)
Abhishek Agarwal created STORM-1625: --- Summary: guava dependency is being shipped inside storm distribution Key: STORM-1625 URL: https://issues.apache.org/jira/browse/STORM-1625 Project: Apache Storm

[jira] [Commented] (STORM-1622) Topology jars referring to shaded classes of older version of storm jar cannot be run in Storm 1.0.0

2016-03-14 Thread Abhishek Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193355#comment-15193355 ] Abhishek Agarwal commented on STORM-1622: - I think it should be ok to just add new

[jira] [Commented] (STORM-1625) guava dependency is being shipped inside storm distribution

2016-03-14 Thread Abhishek Agarwal (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193363#comment-15193363 ] Abhishek Agarwal commented on STORM-1625: - {noformat} [INFO] +- org.apache.storm:s

Re: Different topologies need different schedulers

2016-03-14 Thread Boyang(Jerry) Peng
This can be solved using the Resource Aware Scheduler.  As the resource aware scheduler allows users to specify on a per topology basis what scheduling strategy to use. On Sunday, March 13, 2016 9:52 PM, devopts wrote: Hi all,     I think it is a issue that all topologies only is schedu

[jira] [Assigned] (STORM-1300) port backtype.storm.scheduler.resource-aware-scheduler-test to java

2016-03-14 Thread Zhuo Liu (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhuo Liu reassigned STORM-1300: --- Assignee: Zhuo Liu > port backtype.storm.scheduler.resource-aware-scheduler-test to java > -

[GitHub] storm pull request: Rename README.markdown to README.md.

2016-03-14 Thread jumarko
GitHub user jumarko opened a pull request: https://github.com/apache/storm/pull/1213 Rename README.markdown to README.md. .md extension is more standard one and commonly used. There are already CHANGELOG.md, DEVELOPER.md, and SECURITY.md in this repo so it's also better to be co

[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 a

[jira] [Commented] (STORM-1611) port org.apache.storm.pacemaker.pacemaker to java

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193556#comment-15193556 ] ASF GitHub Bot commented on STORM-1611: --- Github user hustfxj commented on the pull r

Re: Different topologies need different schedulers

2016-03-14 Thread Li Wang
Hi, Under current scheduler implementation, I am afraid this can not be achieved. Would you please specify the reason why you want different topologies to be scheduled by different schedulers. Thanks. Li > On 14 Mar 2016, at 10:51 AM, devopts wrote: > > Hi all, >I think it is a issue th

[GitHub] storm pull request: [STORM-1523] util.clj available-port conversio...

2016-03-14 Thread redsanket
Github user redsanket commented on the pull request: https://github.com/apache/storm/pull/1073#issuecomment-196423667 @harshach upmerged and squashed --- 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 no

[jira] [Commented] (STORM-1523) Translate Available Ports task in util.java

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193685#comment-15193685 ] ASF GitHub Bot commented on STORM-1523: --- Github user redsanket commented on the pull

[jira] [Commented] (STORM-1623) nimbus.clj's minor bug

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193698#comment-15193698 ] ASF GitHub Bot commented on STORM-1623: --- Github user redsanket commented on the pull

[GitHub] storm pull request: [STORM-1623] fix bug about nimbus.clj

2016-03-14 Thread redsanket
Github user redsanket commented on the pull request: https://github.com/apache/storm/pull/1211#issuecomment-196424927 +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 a

[GitHub] storm pull request: STORM-822: Kafka Spout New Consumer API

2016-03-14 Thread hmcl
Github user hmcl commented on a diff in the pull request: https://github.com/apache/storm/pull/1131#discussion_r56041205 --- Diff: external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutStreams.java --- @@ -0,0 +1,142 @@ +/* + * Licensed to the Ap

[jira] [Commented] (STORM-822) As a storm developer I’d like to use the new kafka consumer API (0.8.3) to reduce dependencies and use long term supported kafka apis

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193702#comment-15193702 ] ASF GitHub Bot commented on STORM-822: -- Github user hmcl commented on a diff in the pu

[jira] [Commented] (STORM-1608) Fix stateful topology acking behavior

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193788#comment-15193788 ] ASF GitHub Bot commented on STORM-1608: --- Github user ptgoetz commented on the pull r

[GitHub] storm pull request: [STORM-1608] Fix stateful topology acking beha...

2016-03-14 Thread ptgoetz
Github user ptgoetz commented on the pull request: https://github.com/apache/storm/pull/1190#issuecomment-196447926 +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

[jira] [Commented] (STORM-1608) Fix stateful topology acking behavior

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193807#comment-15193807 ] ASF GitHub Bot commented on STORM-1608: --- Github user revans2 commented on the pull r

[GitHub] storm pull request: [STORM-1608] Fix stateful topology acking beha...

2016-03-14 Thread revans2
Github user revans2 commented on the pull request: https://github.com/apache/storm/pull/1190#issuecomment-196450856 +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

[jira] [Commented] (STORM-1625) guava dependency is being shipped inside storm distribution

2016-03-14 Thread Robert Joseph Evans (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193849#comment-15193849 ] Robert Joseph Evans commented on STORM-1625: I wasn't paying attention to the

[jira] [Commented] (STORM-1602) Blobstore UTs are failed on Windows

2016-03-14 Thread P. Taylor Goetz (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193871#comment-15193871 ] P. Taylor Goetz commented on STORM-1602: +1 for fixing this for 1.0. I don't think

[jira] [Commented] (STORM-1625) guava dependency is being shipped inside storm distribution

2016-03-14 Thread Robert Joseph Evans (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193911#comment-15193911 ] Robert Joseph Evans commented on STORM-1625: OK So I looked at how the code wo

[jira] [Created] (STORM-1626) HBaseBolt tuple counts too high in storm ui.

2016-03-14 Thread Priyank Shah (JIRA)
Priyank Shah created STORM-1626: --- Summary: HBaseBolt tuple counts too high in storm ui. Key: STORM-1626 URL: https://issues.apache.org/jira/browse/STORM-1626 Project: Apache Storm Issue Type: B

[jira] [Commented] (STORM-1625) guava dependency is being shipped inside storm distribution

2016-03-14 Thread P. Taylor Goetz (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193936#comment-15193936 ] P. Taylor Goetz commented on STORM-1625: I totally agree that the SQL dependencies

[GitHub] storm pull request: [STORM-1252] port backtype.storm.stats to java

2016-03-14 Thread revans2
Github user revans2 commented on the pull request: https://github.com/apache/storm/pull/1147#issuecomment-196482345 @unsleepy22 sorry I had a minor personal emergency come up last Friday. It is fixed now, but I am still trying to catch up on everything that happened Friday and over t

[jira] [Commented] (STORM-1252) port backtype.storm.stats to java

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193944#comment-15193944 ] ASF GitHub Bot commented on STORM-1252: --- Github user revans2 commented on the pull r

[GitHub] storm pull request: [STORM-1608] Fix stateful topology acking beha...

2016-03-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/storm/pull/1190 --- 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 enab

[GitHub] storm pull request: [STORM-1608] Fix stateful topology acking beha...

2016-03-14 Thread ptgoetz
Github user ptgoetz commented on the pull request: https://github.com/apache/storm/pull/1190#issuecomment-196487801 Merged to master and 1.x-branch --- 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

[jira] [Commented] (STORM-1608) Fix stateful topology acking behavior

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193987#comment-15193987 ] ASF GitHub Bot commented on STORM-1608: --- Github user asfgit closed the pull request

[jira] [Commented] (STORM-1608) Fix stateful topology acking behavior

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15193988#comment-15193988 ] ASF GitHub Bot commented on STORM-1608: --- Github user ptgoetz commented on the pull r

[jira] [Resolved] (STORM-1608) Fix stateful topology acking behavior

2016-03-14 Thread P. Taylor Goetz (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] P. Taylor Goetz resolved STORM-1608. Resolution: Fixed Fix Version/s: 2.0.0 1.0.0 > Fix stateful topolo

[GitHub] storm pull request: !!! DO NOT MERGE !!! STORM-1617 preview !!! DO...

2016-03-14 Thread revans2
Github user revans2 closed the pull request at: https://github.com/apache/storm/pull/1203 --- 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 ena

[GitHub] storm pull request: !!! DO NOT MERGE !!! STORM-1617 preview !!! DO...

2016-03-14 Thread revans2
Github user revans2 commented on the pull request: https://github.com/apache/storm/pull/1203#issuecomment-196529163 Sounds good I will go ahead with doing all of this in subversion, and put up pull requests in git for release specific docs that we would copy to subversion when we do a

[jira] [Commented] (STORM-1617) storm.apache.org has no release specific documentation

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15194178#comment-15194178 ] ASF GitHub Bot commented on STORM-1617: --- Github user revans2 closed the pull request

[jira] [Commented] (STORM-1617) storm.apache.org has no release specific documentation

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15194177#comment-15194177 ] ASF GitHub Bot commented on STORM-1617: --- Github user revans2 commented on the pull r

[GitHub] storm pull request: STORM-1616: Add RAS API for Trident

2016-03-14 Thread knusbaum
Github user knusbaum commented on a diff in the pull request: https://github.com/apache/storm/pull/1199#discussion_r56084445 --- Diff: storm-core/src/jvm/org/apache/storm/trident/Stream.java --- @@ -124,6 +124,31 @@ public Stream parallelismHint(int hint) { }

[jira] [Commented] (STORM-1616) Add RAS API for Trident

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15194253#comment-15194253 ] ASF GitHub Bot commented on STORM-1616: --- Github user knusbaum commented on a diff in

[GitHub] storm pull request: STORM-1616: Add RAS API for Trident

2016-03-14 Thread knusbaum
Github user knusbaum commented on the pull request: https://github.com/apache/storm/pull/1199#issuecomment-196548786 arunmahadevan added a note 3 days ago > Actually naming the operations wherever specific config needs to be applied looks cleaner and it separates out the stre

[jira] [Commented] (STORM-1616) Add RAS API for Trident

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15194300#comment-15194300 ] ASF GitHub Bot commented on STORM-1616: --- Github user knusbaum commented on the pull

[GitHub] storm pull request: [STORM-1624] add maven central status in READM...

2016-03-14 Thread hustfxj
Github user hustfxj commented on the pull request: https://github.com/apache/storm/pull/1212#issuecomment-196584158 +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

[jira] [Commented] (STORM-1624) add maven central status in README

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15194445#comment-15194445 ] ASF GitHub Bot commented on STORM-1624: --- Github user hustfxj commented on the pull r

[GitHub] storm pull request: STORM-1616: Add RAS API for Trident

2016-03-14 Thread ptgoetz
Github user ptgoetz commented on the pull request: https://github.com/apache/storm/pull/1199#issuecomment-196585455 I lean toward making this part of the Stream API, just like parallelismHint(). In both cases it is about requesting cluster resources, (I.e. Threads/CPU/Memory).

[jira] [Commented] (STORM-1616) Add RAS API for Trident

2016-03-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15194462#comment-15194462 ] ASF GitHub Bot commented on STORM-1616: --- Github user ptgoetz commented on the pull r

  1   2   >