[jira] [Assigned] (STORM-845) Storm ElasticSearch connector

[ https://issues.apache.org/jira/browse/STORM-845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian Seungjin Lee reassigned STORM-845: - Assignee: Adrian Seungjin Lee Storm ElasticSearch connector

[jira] [Created] (STORM-869) kafka spout cannot fetch message if log size is above fetchSizeBytes

Adrian Seungjin Lee created STORM-869: - Summary: kafka spout cannot fetch message if log size is above fetchSizeBytes Key: STORM-869 URL: https://issues.apache.org/jira/browse/STORM-869 Project:

[jira] [Commented] (STORM-869) kafka spout cannot fetch message if log size is above fetchSizeBytes

[ https://issues.apache.org/jira/browse/STORM-869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14587624#comment-14587624 ] Adrian Seungjin Lee commented on STORM-869: --- You can reproduce this by setting

[jira] [Created] (STORM-845) Storm ElasticSearch connector

Adrian Seungjin Lee created STORM-845: - Summary: Storm ElasticSearch connector Key: STORM-845 URL: https://issues.apache.org/jira/browse/STORM-845 Project: Apache Storm Issue Type: New

[jira] [Commented] (STORM-763) nimbus reassigned worker A to another machine, but other worker's netty client can't connect to the new worker A

[ https://issues.apache.org/jira/browse/STORM-763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14518959#comment-14518959 ] Adrian Seungjin Lee commented on STORM-763: --- having same problem with Storm 0.9.4

[jira] [Created] (STORM-805) Supervisor crashes with 'org.apache.commons.io.FileExistsException: Destination already exists' error

Adrian Seungjin Lee created STORM-805: - Summary: Supervisor crashes with 'org.apache.commons.io.FileExistsException: Destination already exists' error Key: STORM-805 URL:

[jira] [Created] (STORM-661) java.io.FileNotFoundException: File 'stormconf.ser' does not exist

Adrian Seungjin Lee created STORM-661: - Summary: java.io.FileNotFoundException: File 'stormconf.ser' does not exist Key: STORM-661 URL: https://issues.apache.org/jira/browse/STORM-661 Project:

[jira] [Created] (STORM-662) java.lang.OutOfMemoryError: Direct buffer memory

Adrian Seungjin Lee created STORM-662: - Summary: java.lang.OutOfMemoryError: Direct buffer memory Key: STORM-662 URL: https://issues.apache.org/jira/browse/STORM-662 Project: Apache Storm

[jira] [Updated] (STORM-618) Add spoutconfig option to make kafka spout process messages at most once.

[ https://issues.apache.org/jira/browse/STORM-618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian Seungjin Lee updated STORM-618: -- Issue Type: Improvement (was: Bug) Add spoutconfig option to make kafka spout process

[jira] [Created] (STORM-618) should provide optional way to implement at-most once semantic

Adrian Seungjin Lee created STORM-618: - Summary: should provide optional way to implement at-most once semantic Key: STORM-618 URL: https://issues.apache.org/jira/browse/STORM-618 Project: Apache

[jira] [Updated] (STORM-618) Add spoutconfig option to make kafka spout process messages at most once.

[ https://issues.apache.org/jira/browse/STORM-618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian Seungjin Lee updated STORM-618: -- Summary: Add spoutconfig option to make kafka spout process messages at most once.