[GitHub] storm pull request: Storm-697: Support for Emitting Kafka Message ...

2015-05-12 Thread lbruand-poctu
Github user lbruand-poctu commented on the pull request: https://github.com/apache/storm/pull/454#issuecomment-101181445 Hi! What is in the way of the merging of these changes ? When can we expect them to be merged ? Cheers, Lucas --- If your project is set u

[jira] [Commented] (STORM-162) Load Balancing Shuffle Grouping

2015-05-12 Thread Gianmarco De Francisci Morales (JIRA)
[ https://issues.apache.org/jira/browse/STORM-162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539654#comment-14539654 ] Gianmarco De Francisci Morales commented on STORM-162: -- Hi, This rece

[jira] [Created] (STORM-815) Auto tuning topologies based on user submitted SLA

2015-05-12 Thread Read Sprabery (JIRA)
Read Sprabery created STORM-815: --- Summary: Auto tuning topologies based on user submitted SLA Key: STORM-815 URL: https://issues.apache.org/jira/browse/STORM-815 Project: Apache Storm Issue Typ

[jira] [Commented] (STORM-815) Auto tuning topologies based on user submitted SLA

2015-05-12 Thread Robert Joseph Evans (JIRA)
[ https://issues.apache.org/jira/browse/STORM-815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14539876#comment-14539876 ] Robert Joseph Evans commented on STORM-815: --- [~rsprabery], I love the idea of ha

[GitHub] storm pull request: STORM-697: allow kafkaSpout to emit message of...

2015-05-12 Thread itachi90
GitHub user itachi90 opened a pull request: https://github.com/apache/storm/pull/549 STORM-697: allow kafkaSpout to emit message offset and partition You can merge this pull request into a Git repository by running: $ git pull https://github.com/Symantec/storm master Alternat

[jira] [Commented] (STORM-697) Support for Emitting Kafka Message Offset and Partition

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540305#comment-14540305 ] ASF GitHub Bot commented on STORM-697: -- GitHub user itachi90 opened a pull request:

[GitHub] storm pull request: STORM-697: allow kafkaSpout to emit message of...

2015-05-12 Thread itachi90
Github user itachi90 closed the pull request at: https://github.com/apache/storm/pull/549 --- 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

[jira] [Commented] (STORM-697) Support for Emitting Kafka Message Offset and Partition

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540310#comment-14540310 ] ASF GitHub Bot commented on STORM-697: -- Github user itachi90 closed the pull request a

[GitHub] storm pull request: STORM-697: Support for Emitting Kafka Message ...

2015-05-12 Thread itachi90
GitHub user itachi90 opened a pull request: https://github.com/apache/storm/pull/550 STORM-697: Support for Emitting Kafka Message Offset and Partition Allow kafkaSpout to emit message offset and partition so that user are able to track tuple using this information. You can merge t

[jira] [Commented] (STORM-697) Support for Emitting Kafka Message Offset and Partition

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540344#comment-14540344 ] ASF GitHub Bot commented on STORM-697: -- GitHub user itachi90 opened a pull request:

[GitHub] storm pull request: STORM-697: Support for Emitting Kafka Message ...

2015-05-12 Thread mjtieman
Github user mjtieman commented on the pull request: https://github.com/apache/storm/pull/550#issuecomment-101366953 STORM-697 is covered by https://github.com/apache/storm/pull/454 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[GitHub] storm pull request: Storm-697: Support for Emitting Kafka Message ...

2015-05-12 Thread mjtieman
Github user mjtieman commented on the pull request: https://github.com/apache/storm/pull/454#issuecomment-101367295 I have never merged into storm before, reading on how to perform the merge. --- If your project is set up for it, you can reply to this email and have your reply appear

[jira] [Commented] (STORM-697) Support for Emitting Kafka Message Offset and Partition

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540363#comment-14540363 ] ASF GitHub Bot commented on STORM-697: -- Github user mjtieman commented on the pull req

[GitHub] storm pull request: STORM-697: Support for Emitting Kafka Message ...

2015-05-12 Thread itachi90
Github user itachi90 closed the pull request at: https://github.com/apache/storm/pull/550 --- 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

[jira] [Commented] (STORM-697) Support for Emitting Kafka Message Offset and Partition

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540386#comment-14540386 ] ASF GitHub Bot commented on STORM-697: -- Github user itachi90 closed the pull request a

[GitHub] storm pull request: [STORM-737] Check task->node+port with read lo...

2015-05-12 Thread d2r
Github user d2r commented on the pull request: https://github.com/apache/storm/pull/521#issuecomment-101382574 @HeartSaVioR Thanks for taking a look. Well, I was trying to follow his comments. :) I noticed though, that the line in my `let` binding ```Clojure v

[jira] [Commented] (STORM-737) Workers may try to send to closed connections

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540454#comment-14540454 ] ASF GitHub Bot commented on STORM-737: -- Github user d2r commented on the pull request:

[GitHub] storm pull request: Storm-697: Support for Emitting Kafka Message ...

2015-05-12 Thread mjtieman
Github user mjtieman commented on the pull request: https://github.com/apache/storm/pull/454#issuecomment-101387750 Apologies, I have to register as an Apache committer before I can merge these changes. --- If your project is set up for it, you can reply to this email and have your

[jira] [Created] (STORM-816) maven-gpg-plugin does not work with gpg 2.1

2015-05-12 Thread Kyle Nusbaum (JIRA)
Kyle Nusbaum created STORM-816: -- Summary: maven-gpg-plugin does not work with gpg 2.1 Key: STORM-816 URL: https://issues.apache.org/jira/browse/STORM-816 Project: Apache Storm Issue Type: Bug

[GitHub] storm pull request: [STORM-816] maven-gpg-plugin does not work wit...

2015-05-12 Thread knusbaum
GitHub user knusbaum opened a pull request: https://github.com/apache/storm/pull/551 [STORM-816] maven-gpg-plugin does not work with gpg 2.1 GPG 2.1 changed some security things involving password entry, and it looks like our version of the plugin doesn't work with it. We s

[jira] [Commented] (STORM-816) maven-gpg-plugin does not work with gpg 2.1

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540856#comment-14540856 ] ASF GitHub Bot commented on STORM-816: -- GitHub user knusbaum opened a pull request:

[jira] [Commented] (STORM-737) Workers may try to send to closed connections

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540918#comment-14540918 ] ASF GitHub Bot commented on STORM-737: -- Github user HeartSaVioR commented on the pull

[GitHub] storm pull request: [STORM-737] Check task->node+port with read lo...

2015-05-12 Thread HeartSaVioR
Github user HeartSaVioR commented on the pull request: https://github.com/apache/storm/pull/521#issuecomment-101446038 @d2r First of all, I'm sorry I did some mistakes about expression. I mean, your approach follows some of Nathan's comment, but not all. Your patch can also

[GitHub] storm pull request: [STORM-737] Check task->node+port with read lo...

2015-05-12 Thread HeartSaVioR
Github user HeartSaVioR commented on the pull request: https://github.com/apache/storm/pull/521#issuecomment-101449371 Please note that packets shouldn't have values which can be changed while passing to transfer flow. task->node+port can be changed (I mean node+port for tuple can

[jira] [Commented] (STORM-737) Workers may try to send to closed connections

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14540936#comment-14540936 ] ASF GitHub Bot commented on STORM-737: -- Github user HeartSaVioR commented on the pull

[jira] [Created] (STORM-817) Kafka Wildcard Topic Support

2015-05-12 Thread Sumit Chawla (JIRA)
Sumit Chawla created STORM-817: -- Summary: Kafka Wildcard Topic Support Key: STORM-817 URL: https://issues.apache.org/jira/browse/STORM-817 Project: Apache Storm Issue Type: New Feature

[jira] [Resolved] (STORM-814) Kafka Spout performance

2015-05-12 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/STORM-814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani resolved STORM-814. -- Resolution: Invalid > Kafka Spout performance > --- > >

[jira] [Commented] (STORM-814) Kafka Spout performance

2015-05-12 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/STORM-814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541117#comment-14541117 ] Sriharsha Chintalapani commented on STORM-814: -- [~rajeshkuch] This is expected

[GitHub] storm pull request: [STORM-816] maven-gpg-plugin does not work wit...

2015-05-12 Thread harshach
Github user harshach commented on the pull request: https://github.com/apache/storm/pull/551#issuecomment-101470751 +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-816) maven-gpg-plugin does not work with gpg 2.1

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541126#comment-14541126 ] ASF GitHub Bot commented on STORM-816: -- Github user harshach commented on the pull req

[GitHub] storm pull request: [STORM-737] Check task->node+port with read lo...

2015-05-12 Thread d2r
Github user d2r commented on the pull request: https://github.com/apache/storm/pull/521#issuecomment-101475237 > @d2r > First of all, I'm sorry I did some mistakes about expression. No worries. > So, I'd like you to review current PR, and find out issues, and go t

[jira] [Commented] (STORM-737) Workers may try to send to closed connections

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541162#comment-14541162 ] ASF GitHub Bot commented on STORM-737: -- Github user d2r commented on the pull request:

[GitHub] storm pull request: [STORM-737] Check task->node+port with read lo...

2015-05-12 Thread d2r
Github user d2r commented on a diff in the pull request: https://github.com/apache/storm/pull/521#discussion_r30196125 --- Diff: storm-core/src/jvm/backtype/storm/utils/TransferDrainer.java --- @@ -26,10 +26,10 @@ public class TransferDrainer { - private HashMa

[jira] [Commented] (STORM-737) Workers may try to send to closed connections

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541164#comment-14541164 ] ASF GitHub Bot commented on STORM-737: -- Github user d2r commented on a diff in the pul

[GitHub] storm pull request: [STORM-737] Check task->node+port with read lo...

2015-05-12 Thread d2r
Github user d2r commented on the pull request: https://github.com/apache/storm/pull/521#issuecomment-101480982 I see 4 test errors using your branch. They all appear to be test timeouts. * integration-test/test-basic-topology * messaging-test/ * test-receiver-messag

[jira] [Commented] (STORM-737) Workers may try to send to closed connections

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541180#comment-14541180 ] ASF GitHub Bot commented on STORM-737: -- Github user d2r commented on the pull request:

[GitHub] storm pull request: [STORM-737] Check task->node+port with read lo...

2015-05-12 Thread d2r
Github user d2r commented on a diff in the pull request: https://github.com/apache/storm/pull/521#discussion_r30197303 --- Diff: storm-core/src/clj/backtype/storm/daemon/worker.clj --- @@ -139,12 +139,12 @@ (.add local pair) ;;Usi

[jira] [Commented] (STORM-737) Workers may try to send to closed connections

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541182#comment-14541182 ] ASF GitHub Bot commented on STORM-737: -- Github user d2r commented on a diff in the pul

[jira] [Commented] (STORM-737) Workers may try to send to closed connections

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541184#comment-14541184 ] ASF GitHub Bot commented on STORM-737: -- Github user HeartSaVioR commented on a diff in

[GitHub] storm pull request: [STORM-737] Check task->node+port with read lo...

2015-05-12 Thread HeartSaVioR
Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/521#discussion_r30197344 --- Diff: storm-core/src/jvm/backtype/storm/utils/TransferDrainer.java --- @@ -26,10 +26,10 @@ public class TransferDrainer { - privat

[GitHub] storm pull request: [STORM-737] Check task->node+port with read lo...

2015-05-12 Thread HeartSaVioR
Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/521#discussion_r30197889 --- Diff: storm-core/src/clj/backtype/storm/daemon/worker.clj --- @@ -139,12 +139,12 @@ (.add local pair)

[jira] [Commented] (STORM-737) Workers may try to send to closed connections

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541193#comment-14541193 ] ASF GitHub Bot commented on STORM-737: -- Github user HeartSaVioR commented on a diff in

[GitHub] storm pull request: [STORM-737] Check task->node+port with read lo...

2015-05-12 Thread HeartSaVioR
Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/521#discussion_r30198050 --- Diff: storm-core/src/clj/backtype/storm/daemon/worker.clj --- @@ -139,12 +139,12 @@ (.add local pair)

[jira] [Commented] (STORM-737) Workers may try to send to closed connections

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541200#comment-14541200 ] ASF GitHub Bot commented on STORM-737: -- Github user HeartSaVioR commented on a diff in

[jira] [Commented] (STORM-814) Kafka Spout performance

2015-05-12 Thread Rajesh Kucharlapati (JIRA)
[ https://issues.apache.org/jira/browse/STORM-814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541210#comment-14541210 ] Rajesh Kucharlapati commented on STORM-814: --- Here is the situation No of Partiti

[jira] [Reopened] (STORM-814) Kafka Spout performance

2015-05-12 Thread Rajesh Kucharlapati (JIRA)
[ https://issues.apache.org/jira/browse/STORM-814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajesh Kucharlapati reopened STORM-814: --- > Kafka Spout performance > --- > > Key: STORM-814 >

[jira] [Commented] (STORM-814) Kafka Spout performance

2015-05-12 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/STORM-814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541222#comment-14541222 ] Sriharsha Chintalapani commented on STORM-814: -- [~rajeshkuch] sorry read it th

[jira] [Commented] (STORM-814) Kafka Spout performance

2015-05-12 Thread Rajesh Kucharlapati (JIRA)
[ https://issues.apache.org/jira/browse/STORM-814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541236#comment-14541236 ] Rajesh Kucharlapati commented on STORM-814: --- Here is the bolt latency information

[jira] [Commented] (STORM-814) Kafka Spout performance

2015-05-12 Thread Rajesh Kucharlapati (JIRA)
[ https://issues.apache.org/jira/browse/STORM-814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541237#comment-14541237 ] Rajesh Kucharlapati commented on STORM-814: --- Here is the bolt latency information

[jira] [Issue Comment Deleted] (STORM-814) Kafka Spout performance

2015-05-12 Thread Rajesh Kucharlapati (JIRA)
[ https://issues.apache.org/jira/browse/STORM-814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajesh Kucharlapati updated STORM-814: -- Comment: was deleted (was: Here is the bolt latency information bol232 32

[jira] [Commented] (STORM-814) Kafka Spout performance

2015-05-12 Thread Nathan Leung (JIRA)
[ https://issues.apache.org/jira/browse/STORM-814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541253#comment-14541253 ] Nathan Leung commented on STORM-814: How is your data pushed to kafka? It is plausible

[GitHub] storm pull request: [STORM-737] Check task->node+port with read lo...

2015-05-12 Thread HeartSaVioR
Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/521#discussion_r30201415 --- Diff: storm-core/src/jvm/backtype/storm/utils/TransferDrainer.java --- @@ -26,10 +26,10 @@ public class TransferDrainer { - privat

[jira] [Commented] (STORM-737) Workers may try to send to closed connections

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541284#comment-14541284 ] ASF GitHub Bot commented on STORM-737: -- Github user HeartSaVioR commented on a diff in

[jira] [Commented] (STORM-737) Workers may try to send to closed connections

2015-05-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14541342#comment-14541342 ] ASF GitHub Bot commented on STORM-737: -- Github user HeartSaVioR commented on the pull

[GitHub] storm pull request: [STORM-737] Check task->node+port with read lo...

2015-05-12 Thread HeartSaVioR
Github user HeartSaVioR commented on the pull request: https://github.com/apache/storm/pull/521#issuecomment-101515533 @d2r I can't reproduce test failures. I'll give it a try again. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub