[jira] [Commented] (KAFKA-6579) Consolidate window store and session store unit tests into a single class

2019-04-02 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16808070#comment-16808070 ] Sophie Blee-Goldman commented on KAFKA-6579: [~benjaminedwardwebb] Are you still working on

[jira] [Created] (KAFKA-8184) Update IQ docs to include session stores

2019-04-02 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8184: -- Summary: Update IQ docs to include session stores Key: KAFKA-8184 URL: https://issues.apache.org/jira/browse/KAFKA-8184 Project: Kafka Issue

[jira] [Created] (KAFKA-8174) Can't call arbitrary SimpleBenchmarks tests from streams_simple_benchmark_test.py

2019-03-28 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8174: -- Summary: Can't call arbitrary SimpleBenchmarks tests from streams_simple_benchmark_test.py Key: KAFKA-8174 URL: https://issues.apache.org/jira/browse/KAFKA-8174

[jira] [Updated] (KAFKA-8159) Built-in serdes for signed numbers do not obey lexicographical ordering

2019-03-28 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8159: --- Description: Currently we assume consistent ordering between serialized and

[jira] [Updated] (KAFKA-8159) Built-in serdes for signed numbers do not obey lexicographical ordering

2019-03-28 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8159: --- Summary: Built-in serdes for signed numbers do not obey lexicographical ordering

[jira] [Created] (KAFKA-8159) Multi-key range queries with negative keyFrom results in unexpected behavior

2019-03-26 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8159: -- Summary: Multi-key range queries with negative keyFrom results in unexpected behavior Key: KAFKA-8159 URL: https://issues.apache.org/jira/browse/KAFKA-8159

[jira] [Updated] (KAFKA-8159) Multi-key range queries with negative keyFrom results in unexpected behavior

2019-03-26 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8159: --- Description: If a user creates a queryable state store using one of the signed

[jira] [Updated] (KAFKA-8159) Multi-key range queries with negative keyFrom results in unexpected behavior

2019-03-27 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8159: --- Description: If a user creates a queryable state store using one of the signed

[jira] [Commented] (KAFKA-8147) Add changelog topic configuration to KTable suppress

2019-04-01 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16807155#comment-16807155 ] Sophie Blee-Goldman commented on KAFKA-8147: [~mjduijn] Just send an email to

[jira] [Comment Edited] (KAFKA-8147) Add changelog topic configuration to KTable suppress

2019-04-01 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16807155#comment-16807155 ] Sophie Blee-Goldman edited comment on KAFKA-8147 at 4/1/19 8:30 PM:

[jira] [Commented] (KAFKA-8159) Multi-key range queries with negative keyFrom results in unexpected behavior

2019-03-26 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16802286#comment-16802286 ] Sophie Blee-Goldman commented on KAFKA-8159: Consider also a user may not explicitly want or

[jira] [Resolved] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-03-01 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-7918. Resolution: Fixed > Streams store cleanup: inline byte-store generic parameters >

[jira] [Resolved] (KAFKA-7912) In-memory key-value store does not support concurrent access

2019-03-01 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-7912. Resolution: Fixed > In-memory key-value store does not support concurrent access

[jira] [Created] (KAFKA-7963) Extract hard-coded strings to centralized place

2019-02-20 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-7963: -- Summary: Extract hard-coded strings to centralized place Key: KAFKA-7963 URL: https://issues.apache.org/jira/browse/KAFKA-7963 Project: Kafka

[jira] [Created] (KAFKA-8007) In-memory window store copies on fetch

2019-02-26 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8007: -- Summary: In-memory window store copies on fetch Key: KAFKA-8007 URL: https://issues.apache.org/jira/browse/KAFKA-8007 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-8094) Iterating over cache with get(key) is inefficient

2019-03-11 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790070#comment-16790070 ] Sophie Blee-Goldman commented on KAFKA-8094: After some investigation, the solution is not as

[jira] [Commented] (KAFKA-8094) Iterating over cache with get(key) is inefficient

2019-03-11 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790080#comment-16790080 ] Sophie Blee-Goldman commented on KAFKA-8094: That said, maybe this is another occasion to

[jira] [Commented] (KAFKA-7652) Kafka Streams Session store performance degradation from 0.10.2.2 to 0.11.0.0

2019-03-14 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793213#comment-16793213 ] Sophie Blee-Goldman commented on KAFKA-7652: Hi [~jonathanpdx]. I've been looking into the

[jira] [Commented] (KAFKA-8027) Gradual decline in performance of CachingWindowStore provider when number of keys grow

2019-03-15 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793994#comment-16793994 ] Sophie Blee-Goldman commented on KAFKA-8027: Hi [~prashantideal], I have been looking into

[jira] [Comment Edited] (KAFKA-8027) Gradual decline in performance of CachingWindowStore provider when number of keys grow

2019-03-15 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16793994#comment-16793994 ] Sophie Blee-Goldman edited comment on KAFKA-8027 at 3/15/19 10:28 PM:

[jira] [Commented] (KAFKA-8042) Kafka Streams creates many segment stores on state restore

2019-03-21 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16798477#comment-16798477 ] Sophie Blee-Goldman commented on KAFKA-8042: I think KAFKA-7934 would certainly fix this

[jira] [Created] (KAFKA-7929) RocksDB Window Store allows segments to expire out from under iterator

2019-02-13 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-7929: -- Summary: RocksDB Window Store allows segments to expire out from under iterator Key: KAFKA-7929 URL: https://issues.apache.org/jira/browse/KAFKA-7929

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-13 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767663#comment-16767663 ] Sophie Blee-Goldman commented on KAFKA-7918: Makes sense, I will consider the caching layer

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-13 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16767611#comment-16767611 ] Sophie Blee-Goldman commented on KAFKA-7918: In light of the decision to close KAFKA-7917 

[jira] [Assigned] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-11 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-7918: -- Assignee: Sophie Blee-Goldman > Streams store cleanup: inline byte-store

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-11 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16765587#comment-16765587 ] Sophie Blee-Goldman commented on KAFKA-7918: For the LRUStore, there are two classes this

[jira] [Issue Comment Deleted] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-11 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-7918: --- Comment: was deleted (was: The RocksDB key-value store is actually already

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-11 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16765585#comment-16765585 ] Sophie Blee-Goldman commented on KAFKA-7918: The RocksDB key-value store is actually already

[jira] [Comment Edited] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-11 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16765587#comment-16765587 ] Sophie Blee-Goldman edited comment on KAFKA-7918 at 2/12/19 1:43 AM: -

[jira] [Commented] (KAFKA-7918) Streams store cleanup: inline byte-store generic parameters

2019-02-11 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16765593#comment-16765593 ] Sophie Blee-Goldman commented on KAFKA-7918: A number of tests will need to be reworked, but

[jira] [Commented] (KAFKA-7934) Optimize restore for windowed and session stores

2019-02-19 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16772534#comment-16772534 ] Sophie Blee-Goldman commented on KAFKA-7934: Is there some reason we can't just work

[jira] [Created] (KAFKA-7912) In-memory key-value store does not support concurrent access

2019-02-08 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-7912: -- Summary: In-memory key-value store does not support concurrent access Key: KAFKA-7912 URL: https://issues.apache.org/jira/browse/KAFKA-7912 Project:

[jira] [Created] (KAFKA-8215) Limit memory usage of RocksDB

2019-04-10 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8215: -- Summary: Limit memory usage of RocksDB Key: KAFKA-8215 URL: https://issues.apache.org/jira/browse/KAFKA-8215 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-6579) Consolidate window store and session store unit tests into a single class

2019-04-10 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-6579: -- Assignee: Sophie Blee-Goldman (was: Ben Webb) > Consolidate window store and

[jira] [Updated] (KAFKA-5636) Add Sliding-Window support for Aggregations

2019-04-14 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-5636: --- Description: We support three windowing types for aggregations in the DSL right now:

[jira] [Created] (KAFKA-8094) Iterating over cache with get(key) is inefficient

2019-03-11 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8094: -- Summary: Iterating over cache with get(key) is inefficient Key: KAFKA-8094 URL: https://issues.apache.org/jira/browse/KAFKA-8094 Project: Kafka

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-05-15 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840588#comment-16840588 ] Sophie Blee-Goldman commented on KAFKA-8367: Actually, even if you are not using the

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-05-15 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16840590#comment-16840590 ] Sophie Blee-Goldman commented on KAFKA-8367: Sorry, commented before I read the ticket. As

[jira] [Issue Comment Deleted] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-05-15 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8367: --- Comment: was deleted (was: Actually, even if you are not using the ConfigSetter the

[jira] [Comment Edited] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-05-16 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841748#comment-16841748 ] Sophie Blee-Goldman edited comment on KAFKA-8367 at 5/16/19 9:46 PM: -

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-05-16 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841748#comment-16841748 ] Sophie Blee-Goldman commented on KAFKA-8367: Hm. I notice in going from 2.0 to 2.1 we

[jira] [Created] (KAFKA-8372) Remove deprecated RocksDB#compactRange API

2019-05-15 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8372: -- Summary: Remove deprecated RocksDB#compactRange API Key: KAFKA-8372 URL: https://issues.apache.org/jira/browse/KAFKA-8372 Project: Kafka Issue

[jira] [Updated] (KAFKA-8347) Choose next record to process by timestamp

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8347: --- Affects Version/s: (was: 2.1.1) 2.1.0 > Choose next

[jira] [Updated] (KAFKA-8347) Choose next record to process by timestamp

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8347: --- Affects Version/s: (was: 2.3.0) 2.2.0

[jira] [Updated] (KAFKA-8347) Choose next record to process by timestamp

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8347: --- Fix Version/s: 2.2.1 2.1.2 > Choose next record to process by

[jira] [Updated] (KAFKA-8215) Limit memory usage of RocksDB

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8215: --- Fix Version/s: 2.3.0 > Limit memory usage of RocksDB > -

[jira] [Resolved] (KAFKA-8215) Limit memory usage of RocksDB

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8215. Resolution: Fixed > Limit memory usage of RocksDB > -

[jira] [Commented] (KAFKA-8478) Poll for more records before forced processing

2019-06-04 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855957#comment-16855957 ] Sophie Blee-Goldman commented on KAFKA-8478: Also related to KAFKA-7458 > Poll for more

[jira] [Updated] (KAFKA-8494) Refactor Consumer#StickyAssignor and add CooperativeStickyAssignor (part 4)

2019-06-14 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8494: --- Summary: Refactor Consumer#StickyAssignor and add CooperativeStickyAssignor (part 4)

[jira] [Resolved] (KAFKA-8491) Bump up Consumer Protocol to v2 (part 1)

2019-06-18 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8491. Resolution: Fixed > Bump up Consumer Protocol to v2 (part 1) >

[jira] [Updated] (KAFKA-4600) Consumer proceeds on when ConsumerRebalanceListener fails

2019-06-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-4600: --- Issue Type: Sub-task (was: Bug) Parent: KAFKA-8179 > Consumer proceeds on

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

2019-06-13 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16863553#comment-16863553 ] Sophie Blee-Goldman commented on KAFKA-8179: KIP-429 will piggy-back a fix for this issue >

[jira] [Assigned] (KAFKA-8510) Update StreamsPartitionAssignor to use the built-in owned partitions to achieve stickiness (part 7)

2019-06-20 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-8510: -- Assignee: Sophie Blee-Goldman > Update StreamsPartitionAssignor to use the

[jira] [Assigned] (KAFKA-8494) Refactor Consumer#StickyAssignor and add CooperativeStickyAssignor (part 4)

2019-06-20 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-8494: -- Assignee: Sophie Blee-Goldman > Refactor Consumer#StickyAssignor and add

[jira] [Updated] (KAFKA-8575) Investigate cleaning up task suspension (part 7)

2019-06-20 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Summary: Investigate cleaning up task suspension (part 7) (was: Investigate

[jira] [Created] (KAFKA-8575) Investigate cleaning up task suspension

2019-06-20 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8575: -- Summary: Investigate cleaning up task suspension Key: KAFKA-8575 URL: https://issues.apache.org/jira/browse/KAFKA-8575 Project: Kafka Issue

[jira] [Updated] (KAFKA-8575) Investigate cleaning up task suspension (part 8)

2019-06-21 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Summary: Investigate cleaning up task suspension (part 8) (was: Investigate

[jira] [Created] (KAFKA-8347) Choose next record to process by timestamp

2019-05-09 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8347: -- Summary: Choose next record to process by timestamp Key: KAFKA-8347 URL: https://issues.apache.org/jira/browse/KAFKA-8347 Project: Kafka Issue

[jira] [Commented] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

2019-05-09 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836606#comment-16836606 ] Sophie Blee-Goldman commented on KAFKA-8315: [~the4thamigo_uk] The code you're looking for

[jira] [Commented] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

2019-05-10 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837765#comment-16837765 ] Sophie Blee-Goldman commented on KAFKA-8315: [~the4thamigo_uk] After I directed you to check

[jira] [Commented] (KAFKA-7994) Improve Stream-Time for rebalances and restarts

2019-05-21 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845381#comment-16845381 ] Sophie Blee-Goldman commented on KAFKA-7994: Hi [~Yohan123], I think we need to be careful in

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-05-23 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847033#comment-16847033 ] Sophie Blee-Goldman commented on KAFKA-8367: How many state stores are present in your

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842778#comment-16842778 ] Sophie Blee-Goldman commented on KAFKA-8367: Bummer. Thanks for helping with the

[jira] [Comment Edited] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842778#comment-16842778 ] Sophie Blee-Goldman edited comment on KAFKA-8367 at 5/17/19 11:11 PM:

[jira] [Updated] (KAFKA-8324) User constructed RocksObjects leak memory

2019-05-17 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8324: --- Affects Version/s: 0.10.1.0 > User constructed RocksObjects leak memory >

[jira] [Commented] (KAFKA-8347) Choose next record to process by timestamp

2019-05-20 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16844233#comment-16844233 ] Sophie Blee-Goldman commented on KAFKA-8347: Oh I missed the RC1 email but you're right, will

[jira] [Updated] (KAFKA-8347) Choose next record to process by timestamp

2019-05-20 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8347: --- Fix Version/s: (was: 2.2.1) 2.2.2 > Choose next record to

[jira] [Updated] (KAFKA-8324) User constructed RocksObjects leak memory

2019-05-03 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8324: --- Description: Some of the RocksDB options a user can set when extending

[jira] [Created] (KAFKA-8323) Memory leak of BloomFilter Rocks object

2019-05-03 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8323: -- Summary: Memory leak of BloomFilter Rocks object Key: KAFKA-8323 URL: https://issues.apache.org/jira/browse/KAFKA-8323 Project: Kafka Issue

[jira] [Created] (KAFKA-8324) User constructed RocksObjects leak memory

2019-05-03 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8324: -- Summary: User constructed RocksObjects leak memory Key: KAFKA-8324 URL: https://issues.apache.org/jira/browse/KAFKA-8324 Project: Kafka Issue

[jira] [Updated] (KAFKA-8323) Memory leak of BloomFilter Rocks object

2019-05-03 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8323: --- Affects Version/s: (was: 2.2.1) (was: 2.3.0)

[jira] [Created] (KAFKA-8295) Optimize count() using RocksDB merge operator

2019-04-26 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8295: -- Summary: Optimize count() using RocksDB merge operator Key: KAFKA-8295 URL: https://issues.apache.org/jira/browse/KAFKA-8295 Project: Kafka

[jira] [Assigned] (KAFKA-8609) Add consumer metrics for rebalances (part 9)

2019-06-27 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-8609: -- Assignee: Sophie Blee-Goldman > Add consumer metrics for rebalances (part 9)

[jira] [Created] (KAFKA-8609) Add consumer metrics for rebalances

2019-06-27 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8609: -- Summary: Add consumer metrics for rebalances Key: KAFKA-8609 URL: https://issues.apache.org/jira/browse/KAFKA-8609 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-8609) Add consumer metrics for rebalances (part 9)

2019-06-27 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8609: --- Summary: Add consumer metrics for rebalances (part 9) (was: Add consumer metrics

[jira] [Comment Edited] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-07-10 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880745#comment-16880745 ] Sophie Blee-Goldman edited comment on KAFKA-8367 at 7/10/19 4:26 PM: -

[jira] [Updated] (KAFKA-8637) WriteBatch objects leak off-heap memory

2019-07-10 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8637: --- Affects Version/s: 2.2.0 2.3.0 Priority: Blocker

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

2019-07-10 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882516#comment-16882516 ] Sophie Blee-Goldman commented on KAFKA-4212: Agreed, this wouldn't be possible within the

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

2019-07-08 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880893#comment-16880893 ] Sophie Blee-Goldman commented on KAFKA-4212: I agree with Matthias that, if we do want to go

[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

2019-07-08 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880886#comment-16880886 ] Sophie Blee-Goldman commented on KAFKA-8630: You're right, I overlooked that

[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

2019-07-08 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880771#comment-16880771 ] Sophie Blee-Goldman commented on KAFKA-8630: Yes, you're likely to hit this problem with some

[jira] [Created] (KAFKA-8627) Investigate batching on state restore

2019-07-03 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8627: -- Summary: Investigate batching on state restore Key: KAFKA-8627 URL: https://issues.apache.org/jira/browse/KAFKA-8627 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8637) WriteBatch objects leak off-heap memory

2019-07-08 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8637: -- Summary: WriteBatch objects leak off-heap memory Key: KAFKA-8637 URL: https://issues.apache.org/jira/browse/KAFKA-8637 Project: Kafka Issue

[jira] [Updated] (KAFKA-8637) WriteBatch objects leak off-heap memory

2019-07-08 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8637: --- Description: In 2.1 we did some refactoring that led to the WriteBatch objects in

[jira] [Commented] (KAFKA-8367) Non-heap memory leak in Kafka Streams

2019-07-08 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880745#comment-16880745 ] Sophie Blee-Goldman commented on KAFKA-8367: Hey [~pavelsavov]! Sorry for the long silence. I

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

2019-07-01 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876516#comment-16876516 ] Sophie Blee-Goldman commented on KAFKA-4212: Hi [~jamesritt], I think your PR is a good first

[jira] [Created] (KAFKA-8603) Document upgrade path

2019-06-25 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8603: -- Summary: Document upgrade path Key: KAFKA-8603 URL: https://issues.apache.org/jira/browse/KAFKA-8603 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-8609) Add consumer metrics for rebalances (part 9)

2019-06-28 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8609: --- Description: We would like to track some additional metrics on the consumer side

[jira] [Updated] (KAFKA-8609) Add consumer metrics for rebalances (part 9)

2019-06-28 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8609: --- Description: We would like to track some additional metrics on the consumer side

[jira] [Commented] (KAFKA-8041) Flaky Test LogDirFailureTest#testIOExceptionDuringLogRoll

2019-08-12 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905426#comment-16905426 ] Sophie Blee-Goldman commented on KAFKA-8041: h3. java.util.concurrent.ExecutionException:

[jira] [Assigned] (KAFKA-8731) InMemorySessionStore throws NullPointerException on startup

2019-07-29 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-8731: -- Assignee: Sophie Blee-Goldman > InMemorySessionStore throws

[jira] [Created] (KAFKA-8807) Flaky Test GlobalThreadShutDownOrderTest.shouldFinishGlobalStoreOperationOnShutDown

2019-08-15 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8807: -- Summary: Flaky Test GlobalThreadShutDownOrderTest.shouldFinishGlobalStoreOperationOnShutDown Key: KAFKA-8807 URL: https://issues.apache.org/jira/browse/KAFKA-8807

[jira] [Commented] (KAFKA-4212) Add a key-value store that is a TTL persistent cache

2019-08-19 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910715#comment-16910715 ] Sophie Blee-Goldman commented on KAFKA-4212: [~jamesritt] By the way, you might want to look

[jira] [Reopened] (KAFKA-7912) In-memory key-value store does not support concurrent access

2019-08-14 Thread Sophie Blee-Goldman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-7912: The fix for this caused a performance regression and is being rolled back. We should

[jira] [Created] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

2019-08-14 Thread Sophie Blee-Goldman (JIRA)
Sophie Blee-Goldman created KAFKA-8802: -- Summary: ConcurrentSkipListMap shows performance regression in cache and in-memory store Key: KAFKA-8802 URL: https://issues.apache.org/jira/browse/KAFKA-8802

[jira] [Commented] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

2019-08-20 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911663#comment-16911663 ] Sophie Blee-Goldman commented on KAFKA-8802: Hi [~f2005...@gmail.com], I can't really give an

[jira] [Updated] (KAFKA-8802) ConcurrentSkipListMap shows performance regression in cache and in-memory store

2019-08-20 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8802: --- Description: The use of ConcurrentSkipListMap in the cache and in-memory stores

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

2019-08-26 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916186#comment-16916186 ] Sophie Blee-Goldman commented on KAFKA-8831: Ah, is this the one that's trace because it will

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

2019-08-26 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916165#comment-16916165 ] Sophie Blee-Goldman commented on KAFKA-8831: [~vinoth] Just to clarify, do you delete all

[jira] [Commented] (KAFKA-8831) Joining a new instance sometimes does not cause rebalancing

2019-08-26 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916203#comment-16916203 ] Sophie Blee-Goldman commented on KAFKA-8831: >>Ah, is this the one that's trace because it

  1   2   3   4   5   6   7   8   9   10   >