[jira] [Commented] (STORM-1311) port backtype.storm.ui.core to java

[ https://issues.apache.org/jira/browse/STORM-1311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15872347#comment-15872347 ] Hugo Louro commented on STORM-1311: --- [~kabhwan] what is the time frame for this. I really would like to

[jira] [Created] (STORM-2374) Storm Kafka Client Test Topologies Must be Serializable

Hugo Louro created STORM-2374: - Summary: Storm Kafka Client Test Topologies Must be Serializable Key: STORM-2374 URL: https://issues.apache.org/jira/browse/STORM-2374 Project: Apache Storm Issue

[jira] [Assigned] (STORM-2362) Cassandra Spout

[ https://issues.apache.org/jira/browse/STORM-2362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2362: - Assignee: Alejandro Fernandez > Cassandra Spout > --- > > Key:

[jira] [Resolved] (STORM-2223) Storm PMML Bolt

[ https://issues.apache.org/jira/browse/STORM-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro resolved STORM-2223. --- Resolution: Fixed > Storm PMML Bolt > --- > > Key: STORM-2223 >

[jira] [Commented] (STORM-2223) Storm PMML Bolt

[ https://issues.apache.org/jira/browse/STORM-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829089#comment-15829089 ] Hugo Louro commented on STORM-2223: --- Merged into master and 1.x-branch > Storm PMML Bolt >

[jira] [Resolved] (STORM-1695) Create trident spout that uses the new kafka consumer API

[ https://issues.apache.org/jira/browse/STORM-1695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro resolved STORM-1695. --- Resolution: Fixed Merged onto master: https://github.com/apache/storm/pull/1687

[jira] [Resolved] (STORM-2097) Improve logging in trident core and examples

[ https://issues.apache.org/jira/browse/STORM-2097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro resolved STORM-2097. --- Resolution: Fixed Merged into master > Improve logging in trident core and examples >

[jira] [Created] (STORM-2208) HDFS State Throws FileNotFoundException in Azure Data Lake Store file system (adl://)

Hugo Louro created STORM-2208: - Summary: HDFS State Throws FileNotFoundException in Azure Data Lake Store file system (adl://) Key: STORM-2208 URL: https://issues.apache.org/jira/browse/STORM-2208

[jira] [Updated] (STORM-2208) HDFS State Throws FileNotFoundException in Azure Data Lake Store file system (adl://)

[ https://issues.apache.org/jira/browse/STORM-2208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2208: -- Priority: Critical (was: Major) > HDFS State Throws FileNotFoundException in Azure Data Lake Store

[jira] [Created] (STORM-2182) Refactor Storm Kafka Examples Into Own Modules

Hugo Louro created STORM-2182: - Summary: Refactor Storm Kafka Examples Into Own Modules Key: STORM-2182 URL: https://issues.apache.org/jira/browse/STORM-2182 Project: Apache Storm Issue Type:

[jira] [Commented] (STORM-2182) Refactor Storm Kafka Examples Into Own Modules

[ https://issues.apache.org/jira/browse/STORM-2182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626033#comment-15626033 ] Hugo Louro commented on STORM-2182: --- - Created modules - storm-kafka-examples -

[jira] [Commented] (STORM-1765) KafkaBolt with new producer api should be part of storm-kaka-client

[ https://issues.apache.org/jira/browse/STORM-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15735732#comment-15735732 ] Hugo Louro commented on STORM-1765: --- [~revans2] does this JIRA still make sense in face of your recent

[jira] [Created] (STORM-2240) STORM PMML Bolt - Add Support to Load Models from Blob Store

Hugo Louro created STORM-2240: - Summary: STORM PMML Bolt - Add Support to Load Models from Blob Store Key: STORM-2240 URL: https://issues.apache.org/jira/browse/STORM-2240 Project: Apache Storm

[jira] [Commented] (STORM-2225) Kafka New API make simple things simple

[ https://issues.apache.org/jira/browse/STORM-2225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15740854#comment-15740854 ] Hugo Louro commented on STORM-2225: --- [~revans2] are you planning on backporting these changes for

[jira] [Updated] (STORM-2223) Storm PMML Bolt

[ https://issues.apache.org/jira/browse/STORM-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2223: -- Affects Version/s: 2.0.0 > Storm PMML Bolt > --- > > Key: STORM-2223 >

[jira] [Commented] (STORM-2236) storm kafka client should support manual partition management.

[ https://issues.apache.org/jira/browse/STORM-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15741182#comment-15741182 ] Hugo Louro commented on STORM-2236: --- Hi [~liurenjie1024] liu, I did not start yet. I was browsing

[jira] [Updated] (STORM-2249) Make Distribution Scripts Put Examples to the Correct Locations

[ https://issues.apache.org/jira/browse/STORM-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2249: -- Description: Make binary.xml put all the examples that exist in source packages with name pattern

[jira] [Commented] (STORM-1765) KafkaBolt with new producer api should be part of storm-kaka-client

[ https://issues.apache.org/jira/browse/STORM-1765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15804835#comment-15804835 ] Hugo Louro commented on STORM-1765: --- [~revans2] OK. Since the JIRA is now assigned to yourself, I will

[jira] [Updated] (STORM-2223) Storm PMML Bolt

[ https://issues.apache.org/jira/browse/STORM-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2223: -- Component/s: storm-pmml > Storm PMML Bolt > --- > > Key: STORM-2223 >

[jira] [Assigned] (STORM-2292) Kafka spout enhancement, for our of range edge cases

[ https://issues.apache.org/jira/browse/STORM-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2292: - Assignee: Hugo Louro > Kafka spout enhancement, for our of range edge cases >

[jira] [Updated] (STORM-2432) Storm-Kafka-Client Trident Spout Seeks Incorrect Offset With UNCOMMITTED_LATEST Strategy

[ https://issues.apache.org/jira/browse/STORM-2432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2432: -- Priority: Critical (was: Blocker) > Storm-Kafka-Client Trident Spout Seeks Incorrect Offset With >

[jira] [Updated] (STORM-2432) Storm-Kafka-Client Trident Spout Seeks Incorrect Offset With UNCOMMITTED_LATEST Strategy

[ https://issues.apache.org/jira/browse/STORM-2432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2432: -- Priority: Blocker (was: Major) > Storm-Kafka-Client Trident Spout Seeks Incorrect Offset With >

[jira] [Created] (STORM-2409) Storm-Kafka-Client KafkaSpout Support for Failed and Null Tuples

Hugo Louro created STORM-2409: - Summary: Storm-Kafka-Client KafkaSpout Support for Failed and Null Tuples Key: STORM-2409 URL: https://issues.apache.org/jira/browse/STORM-2409 Project: Apache Storm

[jira] [Assigned] (STORM-2494) KafkaSpout does not handle CommitFailedException

[ https://issues.apache.org/jira/browse/STORM-2494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2494: - Assignee: Hugo Louro > KafkaSpout does not handle CommitFailedException >

[jira] [Commented] (STORM-2494) KafkaSpout does not handle CommitFailedException

[ https://issues.apache.org/jira/browse/STORM-2494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16128979#comment-16128979 ] Hugo Louro commented on STORM-2494: --- [~Srdo] I understand that. The only reason I decided to put some

[jira] [Updated] (STORM-2052) Kafka Spout New Client API - Log Improvements and Parameter Tuning for Better Performance

[ https://issues.apache.org/jira/browse/STORM-2052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2052: -- Component/s: (was: storm-kafka) storm-kafka-client > Kafka Spout New Client API -

[jira] [Updated] (STORM-2239) New Kafka spout does not properly handle interrupts

[ https://issues.apache.org/jira/browse/STORM-2239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2239: -- Component/s: storm-kafka-client > New Kafka spout does not properly handle interrupts >

[jira] [Updated] (STORM-2104) New Kafka spout crashes if partitions are reassigned while tuples are in-flight

[ https://issues.apache.org/jira/browse/STORM-2104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2104: -- Component/s: (was: storm-kafka) storm-kafka-client > New Kafka spout crashes if

[jira] [Updated] (STORM-1737) storm-kafka-client has compilation errors with Apache Kafka 0.10

[ https://issues.apache.org/jira/browse/STORM-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-1737: -- Component/s: storm-kafka-client > storm-kafka-client has compilation errors with Apache Kafka 0.10 >

[jira] [Resolved] (STORM-1997) Support Kafka Bolt in Storm Kafka Client

[ https://issues.apache.org/jira/browse/STORM-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro resolved STORM-1997. --- Resolution: Fixed Assignee: Robert Joseph Evans (was: darion yaphet) > Support Kafka Bolt in

[jira] [Updated] (STORM-2408) build failed if storm.kafka.client.version = 0.10.2.0

[ https://issues.apache.org/jira/browse/STORM-2408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2408: -- Component/s: storm-kafka-client > build failed if storm.kafka.client.version = 0.10.2.0 >

[jira] [Updated] (STORM-1997) Support Kafka Bolt in Storm Kafka Client

[ https://issues.apache.org/jira/browse/STORM-1997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-1997: -- Component/s: (was: storm-kafka) storm-kafka-client > Support Kafka Bolt in Storm

[jira] [Updated] (STORM-1725) Kafka Spout New Consumer API - KafkaSpoutRetryExponentialBackoff method should use HashMap instead of TreeMap not to throw Exception

[ https://issues.apache.org/jira/browse/STORM-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-1725: -- Component/s: (was: storm-kafka) storm-kafka-client > Kafka Spout New Consumer API

[jira] [Updated] (STORM-2184) New Kafka spout will fail to commit offsets on shutdown if there are offsets to commit

[ https://issues.apache.org/jira/browse/STORM-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2184: -- Component/s: storm-kafka-client > New Kafka spout will fail to commit offsets on shutdown if there are

[jira] [Updated] (STORM-2505) Kafka Spout doesn't support voids in the topic (topic compaction not supported)

[ https://issues.apache.org/jira/browse/STORM-2505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2505: -- Component/s: (was: storm-kafka) storm-kafka-client > Kafka Spout doesn't support

[jira] [Updated] (STORM-2014) New Kafka spout duplicates checking if failed messages have reached max retries

[ https://issues.apache.org/jira/browse/STORM-2014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2014: -- Component/s: (was: storm-kafka) storm-kafka-client > New Kafka spout duplicates

[jira] [Updated] (STORM-1876) Provide option to build storm-kafka against different kafka clients

[ https://issues.apache.org/jira/browse/STORM-1876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-1876: -- Component/s: storm-kafka-client > Provide option to build storm-kafka against different kafka clients >

[jira] [Updated] (STORM-1694) Kafka Spout Trident Implementation Using New Kafka Consumer API

[ https://issues.apache.org/jira/browse/STORM-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-1694: -- Component/s: (was: storm-kafka) storm-kafka-client > Kafka Spout Trident

[jira] [Updated] (STORM-1930) Kafka New Client API - Support for Topic Wildcards

[ https://issues.apache.org/jira/browse/STORM-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-1930: -- Component/s: (was: storm-kafka) storm-kafka-client > Kafka New Client API -

[jira] [Updated] (STORM-1136) Provide a bin script to check consumer lag from KafkaSpout to Kafka topic offsets and integrate with storm ui

[ https://issues.apache.org/jira/browse/STORM-1136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-1136: -- Component/s: storm-kafka-monitor storm-kafka-client > Provide a bin script to check

[jira] [Commented] (STORM-2524) Set Kafka client.id with storm-kafka

[ https://issues.apache.org/jira/browse/STORM-2524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16081502#comment-16081502 ] Hugo Louro commented on STORM-2524: --- Removed component storm-kafka-client because none of the PRs

[jira] [Updated] (STORM-1363) TridentKafkaState should handle null values from TridentTupleToKafkaMapper.getMessageFromTuple()

[ https://issues.apache.org/jira/browse/STORM-1363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-1363: -- Component/s: (was: storm-kafka) > TridentKafkaState should handle null values from >

[jira] [Updated] (STORM-2524) Set Kafka client.id with storm-kafka

[ https://issues.apache.org/jira/browse/STORM-2524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2524: -- Component/s: (was: storm-kafka-client) > Set Kafka client.id with storm-kafka >

[jira] [Updated] (STORM-2182) Refactor Storm Kafka Examples Into Own Modules

[ https://issues.apache.org/jira/browse/STORM-2182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2182: -- Component/s: storm-kafka-client examples > Refactor Storm Kafka Examples Into Own

[jira] [Commented] (STORM-2102) Introduce new sql external module: storm-sql-hbase

[ https://issues.apache.org/jira/browse/STORM-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16088276#comment-16088276 ] Hugo Louro commented on STORM-2102: --- [~vesense] Are you still working on this JIRA? > Introduce new sql

[jira] [Closed] (STORM-2538) New kafka spout emits duplicate tuples

[ https://issues.apache.org/jira/browse/STORM-2538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro closed STORM-2538. - Resolution: Won't Fix Marked as Won't Fix in favor of STORM-2542 > New kafka spout emits duplicate

[jira] [Commented] (STORM-2549) The fix for STORM-2343 is incomplete, and the spout can still get stuck on failed tuples

[ https://issues.apache.org/jira/browse/STORM-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16091618#comment-16091618 ] Hugo Louro commented on STORM-2549: --- [~Srdo] can you please marked this ticket as in progress. Thanks.

[jira] [Comment Edited] (STORM-2342) storm-kafka-client consumer group getting stuck consuming from kafka 0.10.1.1

[ https://issues.apache.org/jira/browse/STORM-2342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16093987#comment-16093987 ] Hugo Louro edited comment on STORM-2342 at 7/20/17 12:05 AM: - [~felipejfc] Do

[jira] [Commented] (STORM-2342) storm-kafka-client consumer group getting stuck consuming from kafka 0.10.1.1

[ https://issues.apache.org/jira/browse/STORM-2342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16093987#comment-16093987 ] Hugo Louro commented on STORM-2342: --- [~felipejfc] Do you still see this problem? Can you please paste

[jira] [Comment Edited] (STORM-2554) Trident Kafka Spout Refactoring to Include Manual Partition Assignment

[ https://issues.apache.org/jira/browse/STORM-2554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16084629#comment-16084629 ] Hugo Louro edited comment on STORM-2554 at 7/20/17 12:07 AM: -

[jira] [Updated] (STORM-2434) Storm spout is not reading/emitting data in storm cluster mode (version 1.0.0)

[ https://issues.apache.org/jira/browse/STORM-2434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2434: -- Component/s: (was: storm-kafka-client) > Storm spout is not reading/emitting data in storm cluster

[jira] [Assigned] (STORM-2542) Deprecate storm-kafka-client KafkaConsumer.subscribe API subscriptions on 1.x and remove them as options in 2.x

[ https://issues.apache.org/jira/browse/STORM-2542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2542: - Assignee: Stig Rohde Døssing (was: Hugo Louro) > Deprecate storm-kafka-client

[jira] [Assigned] (STORM-2542) Deprecate storm-kafka-client KafkaConsumer.subscribe API subscriptions on 1.x and remove them as options in 2.x

[ https://issues.apache.org/jira/browse/STORM-2542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2542: - Assignee: Hugo Louro (was: Stig Rohde Døssing) > Deprecate storm-kafka-client

[jira] [Assigned] (STORM-2230) Unable to send same topic in different streams using KafkaSpoutStreamsNamedTopics

[ https://issues.apache.org/jira/browse/STORM-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2230: - Assignee: Hugo Louro > Unable to send same topic in different streams using >

[jira] [Commented] (STORM-2470) kafkaspout should support kerberos

[ https://issues.apache.org/jira/browse/STORM-2470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16070840#comment-16070840 ] Hugo Louro commented on STORM-2470: --- [~liuzhaokun] [~harsha_ch] [~sriharsha] should this JIRA be closed

[jira] [Assigned] (STORM-2544) Bugs in the Kafka Spout retry logic when using manual commit

[ https://issues.apache.org/jira/browse/STORM-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2544: - Assignee: Hugo Louro > Bugs in the Kafka Spout retry logic when using manual commit >

[jira] [Assigned] (STORM-2544) Bugs in the Kafka Spout retry logic when using manual commit

[ https://issues.apache.org/jira/browse/STORM-2544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2544: - Assignee: Prasanna Ranganathan (was: Hugo Louro) > Bugs in the Kafka Spout retry logic when

[jira] [Closed] (STORM-2230) Unable to send same topic in different streams using KafkaSpoutStreamsNamedTopics

[ https://issues.apache.org/jira/browse/STORM-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro closed STORM-2230. - > Unable to send same topic in different streams using > KafkaSpoutStreamsNamedTopics >

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

[ https://issues.apache.org/jira/browse/STORM-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2541: - Assignee: Stig Rohde Døssing (was: Hugo Louro) > Manual partition assignment doesn't work >

[jira] [Commented] (STORM-2426) First tuples fail after worker is respawn

[ https://issues.apache.org/jira/browse/STORM-2426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16070847#comment-16070847 ] Hugo Louro commented on STORM-2426: --- [~Srdo] Does STORM-2542 fix this bug ? > First tuples fail after

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

[ https://issues.apache.org/jira/browse/STORM-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2541: - Assignee: Hugo Louro (was: Stig Rohde Døssing) > Manual partition assignment doesn't work >

[jira] [Closed] (STORM-2229) KafkaSpout does not resend failed tuples

[ https://issues.apache.org/jira/browse/STORM-2229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro closed STORM-2229. - > KafkaSpout does not resend failed tuples > > >

[jira] [Closed] (STORM-2077) KafkaSpout doesn't retry failed tuples

[ https://issues.apache.org/jira/browse/STORM-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro closed STORM-2077. - > KafkaSpout doesn't retry failed tuples > -- > > Key:

[jira] [Commented] (STORM-2430) Potential Race condition in Kafka Spout

[ https://issues.apache.org/jira/browse/STORM-2430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16070819#comment-16070819 ] Hugo Louro commented on STORM-2430: --- [~Srdo] you have done several improvements related to this. Do you

[jira] [Assigned] (STORM-2302) New Kafka spout doesn't support seek to given offset

[ https://issues.apache.org/jira/browse/STORM-2302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2302: - Assignee: Hugo Louro > New Kafka spout doesn't support seek to given offset >

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

[ https://issues.apache.org/jira/browse/STORM-2607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2607: - Assignee: Hugo Louro > [kafka-client] Consumer group every time with lag 1 >

[jira] [Resolved] (STORM-2230) Unable to send same topic in different streams using KafkaSpoutStreamsNamedTopics

[ https://issues.apache.org/jira/browse/STORM-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro resolved STORM-2230. --- Resolution: Invalid KafkaSpoutStreamsNamedTopics class no longer exists after refactoring done in

[jira] [Assigned] (STORM-2530) Make trident Kafka Spout log its assigned partition

[ https://issues.apache.org/jira/browse/STORM-2530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2530: - Assignee: Hugo Louro > Make trident Kafka Spout log its assigned partition >

[jira] [Updated] (STORM-2442) modify the Usage Examples in storm-kafka-client's README.md

[ https://issues.apache.org/jira/browse/STORM-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2442: -- Issue Type: Improvement (was: Bug) > modify the Usage Examples in storm-kafka-client's README.md >

[jira] [Updated] (STORM-2554) Trident Kafka Spout Refactoring to Include Manual Partition Assignment

[ https://issues.apache.org/jira/browse/STORM-2554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2554: -- Summary: Trident Kafka Spout Refactoring to Include Manual Partition Assignment (was: Storm Kafka

[jira] [Assigned] (STORM-2538) New kafka spout emits duplicate tuples

[ https://issues.apache.org/jira/browse/STORM-2538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2538: - Assignee: Hugo Louro > New kafka spout emits duplicate tuples >

[jira] [Assigned] (STORM-2514) Incorrect logs for mapping between Kafka partitions and task IDs

[ https://issues.apache.org/jira/browse/STORM-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2514: - Assignee: Hugo Louro > Incorrect logs for mapping between Kafka partitions and task IDs >

[jira] [Created] (STORM-2554) Storm Kafka Client Trident Kafka Spout Refactoring to Include Manual Partition Assignment

Hugo Louro created STORM-2554: - Summary: Storm Kafka Client Trident Kafka Spout Refactoring to Include Manual Partition Assignment Key: STORM-2554 URL: https://issues.apache.org/jira/browse/STORM-2554

[jira] [Assigned] (STORM-2554) Storm Kafka Client Trident Kafka Spout Refactoring to Include Manual Partition Assignment

[ https://issues.apache.org/jira/browse/STORM-2554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2554: - Assignee: Hugo Louro > Storm Kafka Client Trident Kafka Spout Refactoring to Include Manual >

[jira] [Resolved] (STORM-2494) KafkaSpout does not handle CommitFailedException

[ https://issues.apache.org/jira/browse/STORM-2494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro resolved STORM-2494. --- Resolution: Fixed Fix Version/s: 1.2.0 STORM-2640 also fixes STORM-2494 > KafkaSpout does not

[jira] [Created] (STORM-2781) Refactor storm-kafka-client KafkaSpout Processing Guarantees

Hugo Louro created STORM-2781: - Summary: Refactor storm-kafka-client KafkaSpout Processing Guarantees Key: STORM-2781 URL: https://issues.apache.org/jira/browse/STORM-2781 Project: Apache Storm

[jira] [Assigned] (STORM-2781) Refactor storm-kafka-client KafkaSpout Processing Guarantees

[ https://issues.apache.org/jira/browse/STORM-2781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2781: - Assignee: Hugo Louro > Refactor storm-kafka-client KafkaSpout Processing Guarantees >

[jira] [Assigned] (STORM-2835) storm-kafka-client KafkaSpout can fail to remove all tuples from waitingToEmit

[ https://issues.apache.org/jira/browse/STORM-2835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2835: - Assignee: Hugo Louro > storm-kafka-client KafkaSpout can fail to remove all tuples from

[jira] [Commented] (STORM-2666) Storm-kafka-client spout can sometimes emit messages that were already committed.

[ https://issues.apache.org/jira/browse/STORM-2666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16277904#comment-16277904 ] Hugo Louro commented on STORM-2666: --- [~Srdo] [~GuangDu] Can you please clarify the comment made at

[jira] [Resolved] (STORM-2835) storm-kafka-client KafkaSpout can fail to remove all tuples from waitingToEmit

[ https://issues.apache.org/jira/browse/STORM-2835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro resolved STORM-2835. --- Resolution: Fixed Fix Version/s: 1.2.0 2.0.0 For discussion thread please

[jira] [Assigned] (STORM-2844) KafkaSpout Throws IllegalStateException After Committing to Kafka When First Poll Strategy Set to EARLIEST

[ https://issues.apache.org/jira/browse/STORM-2844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2844: - Assignee: Hugo Louro > KafkaSpout Throws IllegalStateException After Committing to Kafka When

[jira] [Updated] (STORM-2844) KafkaSpout Throws IllegalStateException After Committing to Kafka When First Poll Strategy Set to EARLIEST

[ https://issues.apache.org/jira/browse/STORM-2844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2844: -- Summary: KafkaSpout Throws IllegalStateException After Committing to Kafka When First Poll Strategy Set

[jira] [Updated] (STORM-2844) f

[ https://issues.apache.org/jira/browse/STORM-2844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2844: -- Summary: f (was: KafkaSpout Throws IllegalStateException After Committing to Kafka When First Poll

[jira] [Created] (STORM-2787) storm-kafka-client should set initialized flag independently of processing guarantees

Hugo Louro created STORM-2787: - Summary: storm-kafka-client should set initialized flag independently of processing guarantees Key: STORM-2787 URL: https://issues.apache.org/jira/browse/STORM-2787

[jira] [Updated] (STORM-2787) storm-kafka-client KafkaSpout should set 'initialized' flag independently of processing guarantees

[ https://issues.apache.org/jira/browse/STORM-2787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2787: -- Summary: storm-kafka-client KafkaSpout should set 'initialized' flag independently of processing

[jira] [Updated] (STORM-2784) storm-kafka-client KafkaTupleListener method onPartitionsReassigned() should be called after initialization is complete

[ https://issues.apache.org/jira/browse/STORM-2784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-2784: -- Summary: storm-kafka-client KafkaTupleListener method onPartitionsReassigned() should be called after

[jira] [Created] (STORM-2784) storm-kafka-client KafkaTupleListener method onPartitionsReassigned should be called after initialization is complete

Hugo Louro created STORM-2784: - Summary: storm-kafka-client KafkaTupleListener method onPartitionsReassigned should be called after initialization is complete Key: STORM-2784 URL:

[jira] [Assigned] (STORM-2784) storm-kafka-client KafkaTupleListener method onPartitionsReassigned should be called after initialization is complete

[ https://issues.apache.org/jira/browse/STORM-2784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro reassigned STORM-2784: - Assignee: Hugo Louro > storm-kafka-client KafkaTupleListener method onPartitionsReassigned

[jira] [Commented] (STORM-2844) KafkaSpout Throws IllegalStateException After Committing to Kafka When First Poll Strategy Set to EARLIEST

[ https://issues.apache.org/jira/browse/STORM-2844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16302599#comment-16302599 ] Hugo Louro commented on STORM-2844: --- [~erikdw] The 1.2.0 and 1.1.x branches have diverged quite a bit

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16345533#comment-16345533 ] Hugo Louro commented on STORM-2914: --- [~Srdo] I am reviewing this patches today. I have going over the

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346102#comment-16346102 ] Hugo Louro commented on STORM-2914: --- [~Srdo] [~kabhwan] [~avermeerbergen] the decision to keep or not

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16346215#comment-16346215 ] Hugo Louro commented on STORM-2914: --- [~kabhwan] I am OK with supporting only at-most-once or

[jira] [Comment Edited] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351147#comment-16351147 ] Hugo Louro edited comment on STORM-2914 at 2/3/18 1:10 AM: --- [~Srdo], [~kabhwan],

[jira] [Comment Edited] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351147#comment-16351147 ] Hugo Louro edited comment on STORM-2914 at 2/3/18 1:08 AM: --- [~Srdo], [~kabhwan],

[jira] [Comment Edited] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351147#comment-16351147 ] Hugo Louro edited comment on STORM-2914 at 2/3/18 1:06 AM: --- [~Srdo], [~kabhwan],

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351147#comment-16351147 ] Hugo Louro commented on STORM-2914: --- [~Srdo][~kabhwan][~avermeerbergen] Let’s try to quickly agree on

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342243#comment-16342243 ] Hugo Louro commented on STORM-2914: --- [~Srdo] I am currently with limited Internet access. I will get my

[jira] [Commented] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351584#comment-16351584 ] Hugo Louro commented on STORM-2914: --- [~Srdo] Thanks for working on this over the weekend. I am going to