[jira] [Resolved] (STORM-2517) storm-hdfs writers can't be subclassed

2017-08-28 Thread Robert Joseph Evans (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Joseph Evans resolved STORM-2517. Resolution: Fixed Fix Version/s: 1.2.0 2.0.0 > storm-hdfs

[jira] [Assigned] (STORM-2517) storm-hdfs writers can't be subclassed

2017-08-28 Thread Robert Joseph Evans (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Joseph Evans reassigned STORM-2517: -- Assignee: Angus Helm > storm-hdfs writers can't be subclassed >

[jira] [Updated] (STORM-2642) Storm-kafka-client spout cannot be serialized when using manual partition assignment

2017-08-28 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stig Rohde Døssing updated STORM-2642: -- Fix Version/s: 1.1.2 > Storm-kafka-client spout cannot be serialized when using manual

[jira] [Updated] (STORM-2541) Manual partition assignment doesn't work

2017-08-28 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stig Rohde Døssing updated STORM-2541: -- Fix Version/s: 1.1.2 > Manual partition assignment doesn't work >

[jira] [Updated] (STORM-2512) Change KafkaSpoutConfig in storm-kafka-client to make it work with flux

2017-08-28 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stig Rohde Døssing updated STORM-2512: -- Fix Version/s: 1.1.2 > Change KafkaSpoutConfig in storm-kafka-client to make it work

[jira] [Updated] (STORM-2607) [kafka-client] Consumer group every time with lag 1

2017-08-28 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stig Rohde Døssing updated STORM-2607: -- Affects Version/s: 2.0.0 > [kafka-client] Consumer group every time with lag 1 >

[jira] [Updated] (STORM-2607) [kafka-client] Consumer group every time with lag 1

2017-08-28 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-2607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stig Rohde Døssing updated STORM-2607: -- Affects Version/s: 1.1.1 > [kafka-client] Consumer group every time with lag 1 >

[jira] [Commented] (STORM-2231) NULL in DisruptorQueue while multi-threaded ack

2017-08-28 Thread Kevin Conaway (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16144262#comment-16144262 ] Kevin Conaway commented on STORM-2231: -- [~kabhwan] btw I can confirm that your patch fixes the issue

[jira] [Comment Edited] (STORM-2231) NULL in DisruptorQueue while multi-threaded ack

2017-08-28 Thread Kevin Conaway (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16143997#comment-16143997 ] Kevin Conaway edited comment on STORM-2231 at 8/28/17 5:14 PM: --- [~kabhwan]

[jira] [Created] (STORM-2712) accept arbitrary number of rows per tuple in storm-cassandra

2017-08-28 Thread Yohei Kishimoto (JIRA)
Yohei Kishimoto created STORM-2712: -- Summary: accept arbitrary number of rows per tuple in storm-cassandra Key: STORM-2712 URL: https://issues.apache.org/jira/browse/STORM-2712 Project: Apache Storm

[jira] [Updated] (STORM-2711) use KafkaTridentSpoutOpaque poll msg slowly.

2017-08-28 Thread shezler (JIRA)
[ https://issues.apache.org/jira/browse/STORM-2711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shezler updated STORM-2711: --- Description: At first I run producer examples to make msgs in kafka, which topic is 5 partition 1

[jira] [Created] (STORM-2711) use KafkaTridentSpoutOpaque poll msg slowly.

2017-08-28 Thread shezler (JIRA)
shezler created STORM-2711: -- Summary: use KafkaTridentSpoutOpaque poll msg slowly. Key: STORM-2711 URL: https://issues.apache.org/jira/browse/STORM-2711 Project: Apache Storm Issue Type: Question