[jira] [Commented] (STORM-2992) Add support for starting storm-kafka-client spout consumer at a specific timestamp

[ https://issues.apache.org/jira/browse/STORM-2992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16400171#comment-16400171 ] Jing Chen commented on STORM-2992: -- I would like to take a stab at this ticket, could you

[jira] [Assigned] (STORM-2992) Add support for starting storm-kafka-client spout consumer at a specific timestamp

[ https://issues.apache.org/jira/browse/STORM-2992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Chen reassigned STORM-2992: Assignee: Jing Chen > Add support for starting storm-kafka-client spout consumer at a specific > t

[jira] [Assigned] (STORM-3064) PartitionedTridentSpoutExecutor should use getPartitionsForTask

[ https://issues.apache.org/jira/browse/STORM-3064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Chen reassigned STORM-3064: Assignee: Jing Chen > PartitionedTridentSpoutExecutor should use getPartitionsForTask > ---

[jira] [Assigned] (STORM-2990) Make the storm-kafka-client Trident spout FirstPollOffsetStrategy behavior consistent with the regular spout

[ https://issues.apache.org/jira/browse/STORM-2990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Chen reassigned STORM-2990: Assignee: Jing Chen > Make the storm-kafka-client Trident spout FirstPollOffsetStrategy behavior

[jira] [Commented] (STORM-2992) Add support for starting storm-kafka-client spout consumer at a specific timestamp

[ https://issues.apache.org/jira/browse/STORM-2992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16550547#comment-16550547 ] Jing Chen commented on STORM-2992: -- [~Srdo] I finished code changes for storm side, howe

[jira] [Assigned] (STORM-2578) Apply new code style to storm-elasticsearch

[ https://issues.apache.org/jira/browse/STORM-2578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Chen reassigned STORM-2578: Assignee: Jing Chen > Apply new code style to storm-elasticsearch > --

[jira] [Assigned] (STORM-2585) Apply new code style to storm-kafka

[ https://issues.apache.org/jira/browse/STORM-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Chen reassigned STORM-2585: Assignee: Jing Chen > Apply new code style to storm-kafka > --- >

[jira] [Commented] (STORM-3214) 使用 kafka.topic.wildcard.match =true的时候，ZkCoordinator.refresh中deletedManagers会出现逻辑错误

[ https://issues.apache.org/jira/browse/STORM-3214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16606876#comment-16606876 ] Jing Chen commented on STORM-3214: -- [~sj] thanks for the catch, I believe it has been fi

[jira] [Commented] (STORM-2318) Look at combining FiledNameTopicSelector and FieldIndexTopicSelector

[ https://issues.apache.org/jira/browse/STORM-2318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16637347#comment-16637347 ] Jing Chen commented on STORM-2318: -- hi [~revans2], do you have any use cases you need to