Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/641#discussion_r35121430
--- Diff:
storm-core/src/jvm/backtype/storm/grouping/PartialKeyGrouping.java ---
@@ -65,7 +66,11 @@ public void prepare(WorkerTopologyContext context,
[
https://issues.apache.org/jira/browse/STORM-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635322#comment-14635322
]
ASF GitHub Bot commented on STORM-139:
--
Github user HeartSaVioR commented on a diff in
Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/641#discussion_r35120287
--- Diff:
storm-core/src/jvm/backtype/storm/grouping/PartialKeyGrouping.java ---
@@ -65,7 +66,11 @@ public void prepare(WorkerTopologyContext context,
[
https://issues.apache.org/jira/browse/STORM-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635303#comment-14635303
]
ASF GitHub Bot commented on STORM-139:
--
Github user d2r commented on a diff in the
[
https://issues.apache.org/jira/browse/STORM-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635414#comment-14635414
]
ASF GitHub Bot commented on STORM-139:
--
Github user d2r commented on a diff in the
Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/641#discussion_r35127032
--- Diff:
storm-core/src/jvm/backtype/storm/grouping/PartialKeyGrouping.java ---
@@ -65,7 +66,11 @@ public void prepare(WorkerTopologyContext context,
[
https://issues.apache.org/jira/browse/STORM-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635467#comment-14635467
]
ASF GitHub Bot commented on STORM-139:
--
Github user d2r commented on a diff in the
Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/641#discussion_r35130923
--- Diff: storm-core/src/clj/backtype/storm/tuple.clj ---
@@ -15,8 +15,11 @@
;; limitations under the License.
(ns backtype.storm.tuple
-
Hi Manu,
Can you share your system configuration to see if I can get the stats using
your setup? I have copy and pasted the output from SOL to show you what I
see.
jack@node-1:/mnt/storm-benchmark$ bin/stormbench -storm
/mnt/storm/bin/storm -jar
Chuanlei Ni created STORM-956:
-
Summary: When the execute() or nextTuple() hang on external
resources, stop the Worker's heartbeat
Key: STORM-956
URL: https://issues.apache.org/jira/browse/STORM-956
Github user arunmahadevan commented on the pull request:
https://github.com/apache/storm/pull/644#issuecomment-123562150
@knusbaum makes sense, have removed wildcard imports.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
GitHub user arunmahadevan opened a pull request:
https://github.com/apache/storm/pull/644
[STORM-837] Support for exactly once semantics in HdfsState
Changes to support exactly once semantics in HdfsState.
1. Moved the file rotation and sync to commit()
2. In
Github user knusbaum commented on a diff in the pull request:
https://github.com/apache/storm/pull/617#discussion_r35155184
--- Diff:
storm-core/src/jvm/backtype/storm/messaging/netty/StormClientHandler.java ---
@@ -0,0 +1,46 @@
+/**
+ * Licensed to the Apache Software
Github user knusbaum commented on a diff in the pull request:
https://github.com/apache/storm/pull/644#discussion_r35155252
--- Diff:
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/HdfsState.java
---
@@ -17,14 +17,14 @@
*/
package
[
https://issues.apache.org/jira/browse/STORM-837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635825#comment-14635825
]
ASF GitHub Bot commented on STORM-837:
--
Github user knusbaum commented on a diff in
[
https://issues.apache.org/jira/browse/STORM-837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635826#comment-14635826
]
ASF GitHub Bot commented on STORM-837:
--
Github user knusbaum commented on a diff in
Github user knusbaum commented on a diff in the pull request:
https://github.com/apache/storm/pull/644#discussion_r35155299
--- Diff:
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/HdfsState.java
---
@@ -40,8 +40,7 @@
import storm.trident.state.State;
GitHub user harshach opened a pull request:
https://github.com/apache/storm/pull/645
STORM-951. Storm Hive connector leaking connections.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/harshach/incubator-storm STORM-951
[
https://issues.apache.org/jira/browse/STORM-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635984#comment-14635984
]
ASF GitHub Bot commented on STORM-951:
--
GitHub user harshach opened a pull request:
[
https://issues.apache.org/jira/browse/STORM-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14635990#comment-14635990
]
ASF GitHub Bot commented on STORM-951:
--
Github user Parth-Brahmbhatt commented on the
[
https://issues.apache.org/jira/browse/STORM-947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634611#comment-14634611
]
ASF GitHub Bot commented on STORM-947:
--
Github user caofangkun commented on a diff in
Github user caofangkun commented on a diff in the pull request:
https://github.com/apache/storm/pull/640#discussion_r35073778
--- Diff: storm-core/src/clj/backtype/storm/scheduler/DefaultScheduler.clj
---
@@ -18,7 +18,7 @@
(:require [backtype.storm.scheduler.EvenScheduler
[
https://issues.apache.org/jira/browse/STORM-837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634566#comment-14634566
]
Arun Mahadevan commented on STORM-837:
--
In HdfsState we support a TimedRotation policy
[
https://issues.apache.org/jira/browse/STORM-918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634873#comment-14634873
]
ASF GitHub Bot commented on STORM-918:
--
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/STORM-918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Joseph Evans resolved STORM-918.
---
Resolution: Fixed
Fix Version/s: 0.11.0
Thanks,
I merged this into master.
[
https://issues.apache.org/jira/browse/STORM-913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634914#comment-14634914
]
ASF GitHub Bot commented on STORM-913:
--
Github user revans2 commented on the pull
GitHub user vesense opened a pull request:
https://github.com/apache/storm/pull/643
using the latest javadocs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vesense/storm patch-5
Alternatively you can review and apply these
[
https://issues.apache.org/jira/browse/STORM-139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634859#comment-14634859
]
ASF GitHub Bot commented on STORM-139:
--
Github user vesense commented on the pull
Github user revans2 commented on the pull request:
https://github.com/apache/storm/pull/632#issuecomment-123243525
+1 looks good to me
---
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 user asfgit closed the pull request at:
https://github.com/apache/storm/pull/632
---
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
caofangkun created STORM-955:
Summary: replace all backtype.storm.daemon.common.clj#StormBase
with backtype.storm.generated.StormBase
Key: STORM-955
URL: https://issues.apache.org/jira/browse/STORM-955
Hi Jack,
I've been successfully getting metrics data running storm-benchmark
wordcount on storm 0.9.5.
Maybe you can file a jira and describe how to reproduce your issue.
Manu
On Tue, Jul 21, 2015 at 9:33 AM, Jack jack.in.teh@gmail.com wrote:
Hi Manu,
I am running version storm 0.9.5
Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/641#discussion_r35109156
--- Diff:
storm-core/src/jvm/backtype/storm/grouping/PartialKeyGrouping.java ---
@@ -65,7 +66,11 @@ public void prepare(WorkerTopologyContext context,
33 matches
Mail list logo
