[jira] [Comment Edited] (STORM-561) Add ability to create topologies dynamically

[ https://issues.apache.org/jira/browse/STORM-561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14232767#comment-14232767 ] John Reilly edited comment on STORM-561 at 12/3/14 8:34 AM: I w

[jira] [Comment Edited] (STORM-561) Add ability to create topologies dynamically

[ https://issues.apache.org/jira/browse/STORM-561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14232767#comment-14232767 ] John Reilly edited comment on STORM-561 at 12/3/14 8:36 AM: I w

[jira] [Commented] (STORM-561) Add ability to create topologies dynamically

[ https://issues.apache.org/jira/browse/STORM-561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14232767#comment-14232767 ] John Reilly commented on STORM-561: --- I was thinking the object itself, not a serialized r

[jira] [Assigned] (STORM-391) KafkaSpout to await for the topic

[ https://issues.apache.org/jira/browse/STORM-391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Sasaki reassigned STORM-391: Assignee: Kai Sasaki > KafkaSpout to await for the topic > - > >

[jira] [Updated] (STORM-391) KafkaSpout to await for the topic

[ https://issues.apache.org/jira/browse/STORM-391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Sasaki updated STORM-391: - Assignee: (was: Kai Sasaki) > KafkaSpout to await for the topic > - > >

[jira] [Created] (STORM-582) Nimbus Halt with FileNotFoundException: '../nimbus/../stormconf.ser' dose not exists

Jiahong Li created STORM-582: Summary: Nimbus Halt with FileNotFoundException: '../nimbus/../stormconf.ser' dose not exists Key: STORM-582 URL: https://issues.apache.org/jira/browse/STORM-582 Project: Apa

[jira] [Updated] (STORM-582) Nimbus Halt with FileNotFoundException: '../nimbus/../stormconf.ser' dose not exists

[ https://issues.apache.org/jira/browse/STORM-582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiahong Li updated STORM-582: - Description: To notice, it is different from STORM-130. It is nimbus to halt. We ran into this problem se

[jira] [Commented] (STORM-582) Nimbus Halt with FileNotFoundException: '../nimbus/../stormconf.ser' dose not exists

[ https://issues.apache.org/jira/browse/STORM-582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14233065#comment-14233065 ] Sriharsha Chintalapani commented on STORM-582: -- [~Gvain] any reason for you to

[jira] [Comment Edited] (STORM-582) Nimbus Halt with FileNotFoundException: '../nimbus/../stormconf.ser' dose not exists

[ https://issues.apache.org/jira/browse/STORM-582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14233065#comment-14233065 ] Sriharsha Chintalapani edited comment on STORM-582 at 12/3/14 2:48 PM: --

bolt stop receiving tuples

Hello All, I have this configuration: spout -> Bolt A (emits tuples) -> Bolt B Bolt A emits tuples successfully but bolt B stops receiving tuples after the first time (it never enters the execute after the first time). The first time execution seems to be successful. Any idea what the issue coul

[jira] [Commented] (STORM-391) KafkaSpout to await for the topic

[ https://issues.apache.org/jira/browse/STORM-391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14233227#comment-14233227 ] Sriharsha Chintalapani commented on STORM-391: -- [~lewuathe] can you make this

[jira] [Commented] (STORM-561) Add ability to create topologies dynamically

[ https://issues.apache.org/jira/browse/STORM-561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14233550#comment-14233550 ] Nathan Leung commented on STORM-561: Can you clarify? In this case do you mean you wou

[jira] [Comment Edited] (STORM-561) Add ability to create topologies dynamically

[ https://issues.apache.org/jira/browse/STORM-561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14233550#comment-14233550 ] Nathan Leung edited comment on STORM-561 at 12/3/14 9:29 PM: - C

[jira] [Created] (STORM-583) Add spout and bolt implementation for Azure Eventhubs

shanyu zhao created STORM-583: - Summary: Add spout and bolt implementation for Azure Eventhubs Key: STORM-583 URL: https://issues.apache.org/jira/browse/STORM-583 Project: Apache Storm Issue Type

[jira] [Commented] (STORM-583) Add spout and bolt implementation for Azure Eventhubs

[ https://issues.apache.org/jira/browse/STORM-583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14233635#comment-14233635 ] shanyu zhao commented on STORM-583: --- This is the pull request: https://github.com/apache/

[jira] [Assigned] (STORM-511) Storm-Kafka spout keeps sending fetch requests with invalid offset

[ https://issues.apache.org/jira/browse/STORM-511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani reassigned STORM-511: Assignee: Sriharsha Chintalapani > Storm-Kafka spout keeps sending fetch req

[jira] [Commented] (STORM-511) Storm-Kafka spout keeps sending fetch requests with invalid offset

[ https://issues.apache.org/jira/browse/STORM-511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14233711#comment-14233711 ] Sriharsha Chintalapani commented on STORM-511: -- Sorry keyboard shortcuts acted

[jira] [Updated] (STORM-511) Storm-Kafka spout keeps sending fetch requests with invalid offset

[ https://issues.apache.org/jira/browse/STORM-511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated STORM-511: - Assignee: Viktor Taranenko (was: Sriharsha Chintalapani) > Storm-Kafka spout keeps

[jira] [Commented] (STORM-391) KafkaSpout to await for the topic

[ https://issues.apache.org/jira/browse/STORM-391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14233722#comment-14233722 ] Kai Sasaki commented on STORM-391: -- [~sriharsha] I'm implementing this option with a event

[jira] [Assigned] (STORM-391) KafkaSpout to await for the topic

[ https://issues.apache.org/jira/browse/STORM-391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kai Sasaki reassigned STORM-391: Assignee: Kai Sasaki > KafkaSpout to await for the topic > - > >

[jira] [Commented] (STORM-561) Add ability to create topologies dynamically

[ https://issues.apache.org/jira/browse/STORM-561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14233795#comment-14233795 ] John Reilly commented on STORM-561: --- I was using spring as an example, but it should be e

[jira] [Commented] (STORM-561) Add ability to create topologies dynamically

[ https://issues.apache.org/jira/browse/STORM-561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14233947#comment-14233947 ] Nathan Marz commented on STORM-561: --- [~amontalenti] Why are you using the Clojure DSL for

[jira] [Comment Edited] (STORM-561) Add ability to create topologies dynamically

[ https://issues.apache.org/jira/browse/STORM-561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14233947#comment-14233947 ] Nathan Marz edited comment on STORM-561 at 12/4/14 6:36 AM: [~a