[
https://issues.apache.org/jira/browse/STORM-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168095#comment-14168095
]
ASF GitHub Bot commented on STORM-513:
--
Github user itaifrenkel commented on a diff in
Github user itaifrenkel commented on a diff in the pull request:
https://github.com/apache/storm/pull/286#discussion_r18741096
--- Diff: storm-core/src/jvm/backtype/storm/spout/ShellSpout.java ---
@@ -189,9 +205,52 @@ private void handleLog(ShellMsg shellMsg) {
Github user itaifrenkel commented on a diff in the pull request:
https://github.com/apache/storm/pull/286#discussion_r18741104
--- Diff: storm-core/src/jvm/backtype/storm/spout/ShellSpout.java ---
@@ -189,9 +205,52 @@ private void handleLog(ShellMsg shellMsg) {
[
https://issues.apache.org/jira/browse/STORM-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168096#comment-14168096
]
ASF GitHub Bot commented on STORM-513:
--
Github user itaifrenkel commented on a diff in
Github user itaifrenkel commented on a diff in the pull request:
https://github.com/apache/storm/pull/286#discussion_r18741180
--- Diff: storm-core/src/jvm/backtype/storm/spout/ShellSpout.java ---
@@ -189,9 +205,52 @@ private void handleLog(ShellMsg shellMsg) {
[
https://issues.apache.org/jira/browse/STORM-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168106#comment-14168106
]
ASF GitHub Bot commented on STORM-513:
--
Github user itaifrenkel commented on a diff in
Github user itaifrenkel commented on a diff in the pull request:
https://github.com/apache/storm/pull/286#discussion_r18741189
--- Diff: storm-core/src/dev/resources/storm.js ---
@@ -243,6 +243,12 @@ BasicBolt.prototype.__emit = function(commandDetails) {
[
https://issues.apache.org/jira/browse/STORM-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168108#comment-14168108
]
ASF GitHub Bot commented on STORM-513:
--
Github user itaifrenkel commented on a diff in
Github user itaifrenkel commented on a diff in the pull request:
https://github.com/apache/storm/pull/286#discussion_r18741213
--- Diff: storm-core/src/jvm/backtype/storm/spout/ShellSpout.java ---
@@ -56,13 +64,18 @@ public void open(Map stormConf, TopologyContext context,
[
https://issues.apache.org/jira/browse/STORM-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168114#comment-14168114
]
ASF GitHub Bot commented on STORM-513:
--
Github user itaifrenkel commented on a diff in
Github user itaifrenkel commented on a diff in the pull request:
https://github.com/apache/storm/pull/286#discussion_r18741231
--- Diff: storm-core/src/jvm/backtype/storm/spout/ShellSpout.java ---
@@ -56,13 +64,18 @@ public void open(Map stormConf, TopologyContext context,
[
https://issues.apache.org/jira/browse/STORM-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168130#comment-14168130
]
ASF GitHub Bot commented on STORM-513:
--
Github user HeartSaVioR commented on a diff in
[
https://issues.apache.org/jira/browse/STORM-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168132#comment-14168132
]
ASF GitHub Bot commented on STORM-513:
--
Github user HeartSaVioR commented on a diff in
GitHub user itaifrenkel opened a pull request:
https://github.com/apache/storm/pull/291
[STORM-529] Send fail(tup) when BasicBolt process throws Exception
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/forter/storm
[
https://issues.apache.org/jira/browse/STORM-529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168136#comment-14168136
]
ASF GitHub Bot commented on STORM-529:
--
GitHub user itaifrenkel opened a pull request:
Itai Frenkel created STORM-529:
--
Summary: Python BasicBolt does not behave as the Java BasicBolt
Key: STORM-529
URL: https://issues.apache.org/jira/browse/STORM-529
Project: Apache Storm
Issue
[
https://issues.apache.org/jira/browse/STORM-529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168137#comment-14168137
]
ASF GitHub Bot commented on STORM-529:
--
Github user itaifrenkel commented on the pull
[
https://issues.apache.org/jira/browse/STORM-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168144#comment-14168144
]
ASF GitHub Bot commented on STORM-513:
--
Github user HeartSaVioR commented on a diff in
Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/286#discussion_r18741514
--- Diff: storm-core/src/dev/resources/storm.js ---
@@ -243,6 +243,12 @@ BasicBolt.prototype.__emit = function(commandDetails) {
[
https://issues.apache.org/jira/browse/STORM-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168149#comment-14168149
]
ASF GitHub Bot commented on STORM-513:
--
Github user HeartSaVioR commented on a diff in
Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/286#discussion_r18741678
--- Diff: storm-core/src/dev/resources/storm.js ---
@@ -243,6 +243,12 @@ BasicBolt.prototype.__emit = function(commandDetails) {
[
https://issues.apache.org/jira/browse/STORM-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168157#comment-14168157
]
ASF GitHub Bot commented on STORM-513:
--
Github user HeartSaVioR commented on a diff in
Github user itaifrenkel commented on a diff in the pull request:
https://github.com/apache/storm/pull/286#discussion_r18742262
--- Diff: storm-core/src/jvm/backtype/storm/spout/ShellSpout.java ---
@@ -189,9 +207,53 @@ private void handleLog(ShellMsg shellMsg) {
[
https://issues.apache.org/jira/browse/STORM-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168217#comment-14168217
]
ASF GitHub Bot commented on STORM-513:
--
Github user itaifrenkel commented on a diff in
So, I assume that acking is performed per batch of tuples. If that is the
case how does the performance of trident compare with the performance of
bolt with acking disabled? thanks.
On Thu, Oct 9, 2014 at 1:10 PM, Nathan Marz nat...@nathanmarz.com wrote:
Trident will not run properly without
Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/286#discussion_r18745292
--- Diff: storm-core/src/jvm/backtype/storm/spout/ShellSpout.java ---
@@ -56,13 +66,18 @@ public void open(Map stormConf, TopologyContext context,
Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/286#discussion_r18745322
--- Diff: storm-core/src/jvm/backtype/storm/spout/ShellSpout.java ---
@@ -189,9 +207,53 @@ private void handleLog(ShellMsg shellMsg) {
[
https://issues.apache.org/jira/browse/STORM-457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168495#comment-14168495
]
Naresh C Kosgi commented on STORM-457:
--
I think this is a non-issue and can be closed?
Github user itaifrenkel commented on a diff in the pull request:
https://github.com/apache/storm/pull/286#discussion_r18745857
--- Diff: storm-core/src/jvm/backtype/storm/spout/ShellSpout.java ---
@@ -189,9 +207,53 @@ private void handleLog(ShellMsg shellMsg) {
[
https://issues.apache.org/jira/browse/STORM-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14168533#comment-14168533
]
ASF GitHub Bot commented on STORM-513:
--
Github user itaifrenkel commented on a diff in
Github user itaifrenkel commented on a diff in the pull request:
https://github.com/apache/storm/pull/286#discussion_r18745860
--- Diff: storm-core/src/jvm/backtype/storm/spout/ShellSpout.java ---
@@ -56,13 +67,18 @@ public void open(Map stormConf, TopologyContext context,
31 matches
Mail list logo