[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058127#comment-17058127 ] Sophie Blee-Goldman commented on KAFKA-9225: Nice! Big thanks to the RocksDB folks for

[jira] [Commented] (KAFKA-9603) Number of open files keeps increasing in Streams application

[ https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058145#comment-17058145 ] Sophie Blee-Goldman commented on KAFKA-9603: Hey [~biljazovic] any new info or results? It

[jira] [Updated] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9168: --- Fix Version/s: 3.0.0 > Integrate JNI direct buffer support to RocksDBStore >

[jira] [Updated] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9168: --- Priority: Blocker (was: Minor) > Integrate JNI direct buffer support to

[jira] [Commented] (KAFKA-9168) Integrate JNI direct buffer support to RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058193#comment-17058193 ] Sophie Blee-Goldman commented on KAFKA-9168: Thanks [~sagarrao], marking this as a blocker

[jira] [Assigned] (KAFKA-9501) Promote Standby tasks to active tasks without closing them

[ https://issues.apache.org/jira/browse/KAFKA-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9501: -- Assignee: Sophie Blee-Goldman > Promote Standby tasks to active tasks without

[jira] [Created] (KAFKA-9846) Race condition can lead to severe lag underestimate for active tasks

Sophie Blee-Goldman created KAFKA-9846: -- Summary: Race condition can lead to severe lag underestimate for active tasks Key: KAFKA-9846 URL: https://issues.apache.org/jira/browse/KAFKA-9846

[jira] [Commented] (KAFKA-9664) Flaky Test KafkaStreamsTest#testStateThreadClose

[ https://issues.apache.org/jira/browse/KAFKA-9664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078660#comment-17078660 ] Sophie Blee-Goldman commented on KAFKA-9664: Huh...I can't seem to track down where I saw

[jira] [Commented] (KAFKA-9831) Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]

[ https://issues.apache.org/jira/browse/KAFKA-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078565#comment-17078565 ] Sophie Blee-Goldman commented on KAFKA-9831: h3. Error Message java.lang.AssertionError:

[jira] [Assigned] (KAFKA-9846) Race condition can lead to severe lag underestimate for active tasks

[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9846: -- Assignee: Vinoth Chandar > Race condition can lead to severe lag

[jira] [Commented] (KAFKA-9846) Race condition can lead to severe lag underestimate for active tasks

[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080145#comment-17080145 ] Sophie Blee-Goldman commented on KAFKA-9846: Hey [~vinoth], just to clarify, the CREATED

[jira] [Updated] (KAFKA-9846) Race condition can lead to severe lag underestimate for active tasks

[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9846: --- Priority: Critical (was: Major) > Race condition can lead to severe lag

[jira] [Commented] (KAFKA-9831) Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]

[ https://issues.apache.org/jira/browse/KAFKA-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078817#comment-17078817 ] Sophie Blee-Goldman commented on KAFKA-9831: Failed twice on the same build: h3. Error

[jira] [Commented] (KAFKA-9846) Race condition can lead to severe lag underestimate for active tasks

[ https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080636#comment-17080636 ] Sophie Blee-Goldman commented on KAFKA-9846: True, the literal Task.State was introduced for

[jira] [Commented] (KAFKA-9831) Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]

[ https://issues.apache.org/jira/browse/KAFKA-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083598#comment-17083598 ] Sophie Blee-Goldman commented on KAFKA-9831: I don't think either of the bugs exposed by soak

[jira] [Created] (KAFKA-9868) Flaky Test EOSUncleanShutdownIntegrationTest.shouldWorkWithUncleanShutdownWipeOutStateStore

Sophie Blee-Goldman created KAFKA-9868: -- Summary: Flaky Test EOSUncleanShutdownIntegrationTest.shouldWorkWithUncleanShutdownWipeOutStateStore Key: KAFKA-9868 URL:

[jira] [Commented] (KAFKA-9818) Flaky Test RecordCollectorTest.shouldNotThrowStreamsExceptionOnSubsequentCallIfASendFailsWithContinueExceptionHandler

[ https://issues.apache.org/jira/browse/KAFKA-9818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082726#comment-17082726 ] Sophie Blee-Goldman commented on KAFKA-9818: [~mjsax] thanks for the improved error logging,

[jira] [Commented] (KAFKA-9568) Kstreams APPLICATION_SERVER_CONFIG is not updated with static membership

[ https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059093#comment-17059093 ] Sophie Blee-Goldman commented on KAFKA-9568: In KIP-568/KAFKA-9525 we added a new

[jira] [Commented] (KAFKA-8803) Stream will not start due to TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

[ https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060403#comment-17060403 ] Sophie Blee-Goldman commented on KAFKA-8803: [~guozhang] do you think the bug(s) you've

[jira] [Updated] (KAFKA-9818) Flaky Test RecordCollectorTest.shouldNotThrowStreamsExceptionOnSubsequentCallIfASendFailsWithContinueExceptionHandler

[ https://issues.apache.org/jira/browse/KAFKA-9818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9818: --- Labels: flaky-test (was: ) > Flaky Test >

[jira] [Created] (KAFKA-9819) Flaky Test StoreChangelogReaderTest#shouldNotThrowOnUnknownRevokedPartition[0]

Sophie Blee-Goldman created KAFKA-9819: -- Summary: Flaky Test StoreChangelogReaderTest#shouldNotThrowOnUnknownRevokedPartition[0] Key: KAFKA-9819 URL: https://issues.apache.org/jira/browse/KAFKA-9819

[jira] [Created] (KAFKA-9818) Flaky Test RecordCollectorTest.shouldNotThrowStreamsExceptionOnSubsequentCallIfASendFailsWithContinueExceptionHandler

Sophie Blee-Goldman created KAFKA-9818: -- Summary: Flaky Test RecordCollectorTest.shouldNotThrowStreamsExceptionOnSubsequentCallIfASendFailsWithContinueExceptionHandler Key: KAFKA-9818 URL:

[jira] [Commented] (KAFKA-9821) Partition may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17075003#comment-17075003 ] Sophie Blee-Goldman commented on KAFKA-9821: What do you think about trying to improve the

[jira] [Commented] (KAFKA-9783) Flaky Test QueryableStateIntegrationTest#concurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071381#comment-17071381 ] Sophie Blee-Goldman commented on KAFKA-9783:

[jira] [Updated] (KAFKA-9923) Join window store duplicates can be compacted in changelog

[ https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9923: --- Fix Version/s: 2.6.0 > Join window store duplicates can be compacted in changelog >

[jira] [Updated] (KAFKA-9923) Join window store duplicates can be compacted in changelog

[ https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9923: --- Priority: Blocker (was: Critical) > Join window store duplicates can be compacted

[jira] [Commented] (KAFKA-7317) Use collections subscription for main consumer to reduce metadata

[ https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094797#comment-17094797 ] Sophie Blee-Goldman commented on KAFKA-7317: Also fixed via 

[jira] [Commented] (KAFKA-9127) Needless group coordination overhead for GlobalKTables

[ https://issues.apache.org/jira/browse/KAFKA-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094801#comment-17094801 ] Sophie Blee-Goldman commented on KAFKA-9127: Yep, if you can kick off tests on that PR and

[jira] [Commented] (KAFKA-7317) Use collections subscription for main consumer to reduce metadata

[ https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093678#comment-17093678 ] Sophie Blee-Goldman commented on KAFKA-7317: I replied on the SO question, but the gist is

[jira] [Created] (KAFKA-9923) Join window store duplicates can be compacted in changelog

Sophie Blee-Goldman created KAFKA-9923: -- Summary: Join window store duplicates can be compacted in changelog Key: KAFKA-9923 URL: https://issues.apache.org/jira/browse/KAFKA-9923 Project: Kafka

[jira] [Updated] (KAFKA-9923) Join window store duplicates can be compacted in changelog

[ https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9923: --- Priority: Critical (was: Major) > Join window store duplicates can be compacted in

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093785#comment-17093785 ] Sophie Blee-Goldman commented on KAFKA-7965:

[jira] [Commented] (KAFKA-9127) Needless group coordination overhead for GlobalKTables

[ https://issues.apache.org/jira/browse/KAFKA-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093685#comment-17093685 ] Sophie Blee-Goldman commented on KAFKA-9127: Does it qualify as a regression when the

[jira] [Commented] (KAFKA-9127) Needless group coordination overhead for GlobalKTables

[ https://issues.apache.org/jira/browse/KAFKA-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093692#comment-17093692 ] Sophie Blee-Goldman commented on KAFKA-9127: That said, it does seem like a lot of users are

[jira] [Reopened] (KAFKA-9798) Flaky test: org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldAllowConcurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9798: Assignee: (was: Guozhang Wang) > Flaky test: >

[jira] [Commented] (KAFKA-9798) Flaky test: org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldAllowConcurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093740#comment-17093740 ] Sophie Blee-Goldman commented on KAFKA-9798: h3. Stacktrace java.lang.AssertionError: Did

[jira] [Commented] (KAFKA-9798) Flaky test: org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldAllowConcurrentAccesses

[ https://issues.apache.org/jira/browse/KAFKA-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093739#comment-17093739 ] Sophie Blee-Goldman commented on KAFKA-9798: h3. Stacktrace

[jira] [Reopened] (KAFKA-9176) Flaky test failure: OptimizedKTableIntegrationTest.shouldApplyUpdatesToStandbyStore

[ https://issues.apache.org/jira/browse/KAFKA-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9176: Saw this fail again on a PR with h3. Stacktrace

[jira] [Comment Edited] (KAFKA-9923) Join window store duplicates can be compacted in changelog

[ https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093842#comment-17093842 ] Sophie Blee-Goldman edited comment on KAFKA-9923 at 4/27/20, 7:00 PM:

[jira] [Commented] (KAFKA-9923) Join window store duplicates can be compacted in changelog

[ https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093842#comment-17093842 ] Sophie Blee-Goldman commented on KAFKA-9923: The root cause is the same but the implications

[jira] [Comment Edited] (KAFKA-9923) Join window store duplicates can be compacted in changelog

[ https://issues.apache.org/jira/browse/KAFKA-9923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093842#comment-17093842 ] Sophie Blee-Goldman edited comment on KAFKA-9923 at 4/27/20, 7:35 PM:

[jira] [Commented] (KAFKA-9921) Caching is not working properly with WindowStateStore when rataining duplicates

[ https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093902#comment-17093902 ] Sophie Blee-Goldman commented on KAFKA-9921: Hey [~georgi.petkov] You're right that there

[jira] [Assigned] (KAFKA-9921) Caching is not working properly with WindowStateStore when rataining duplicates

[ https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9921: -- Assignee: Sophie Blee-Goldman > Caching is not working properly with

[jira] [Commented] (KAFKA-9921) Caching is not working properly with WindowStateStore when rataining duplicates

[ https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094835#comment-17094835 ] Sophie Blee-Goldman commented on KAFKA-9921: > For 2 puts I would expect 2 entries regardless

[jira] [Commented] (KAFKA-9921) Caching is not working properly with WindowStateStore when rataining duplicates

[ https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094839#comment-17094839 ] Sophie Blee-Goldman commented on KAFKA-9921: I take it you're using rocksdb, by the way? If

[jira] [Updated] (KAFKA-9921) Caching is not working properly with WindowStateStore when rataining duplicates

[ https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9921: --- Fix Version/s: 2.5.1 > Caching is not working properly with WindowStateStore when

[jira] [Commented] (KAFKA-9921) Caching is not working properly with WindowStateStore when rataining duplicates

[ https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17094844#comment-17094844 ] Sophie Blee-Goldman commented on KAFKA-9921: I'm resolving the ticket because the PR to

[jira] [Assigned] (KAFKA-9127) Needless group coordination overhead for GlobalKTables

[ https://issues.apache.org/jira/browse/KAFKA-9127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9127: -- Assignee: Sophie Blee-Goldman > Needless group coordination overhead for

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089107#comment-17089107 ] Sophie Blee-Goldman commented on KAFKA-7965:

[jira] [Created] (KAFKA-9898) Flaky Test StoreQueryIntegrationTest.shouldQueryAllStalePartitionStores

Sophie Blee-Goldman created KAFKA-9898: -- Summary: Flaky Test StoreQueryIntegrationTest.shouldQueryAllStalePartitionStores Key: KAFKA-9898 URL: https://issues.apache.org/jira/browse/KAFKA-9898

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

[ https://issues.apache.org/jira/browse/KAFKA-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-5636: -- Assignee: Sophie Blee-Goldman > Add Sliding-Window support for Aggregations >

[jira] [Assigned] (KAFKA-7497) Kafka Streams should support self-join on streams

[ https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-7497: -- Assignee: Sophie Blee-Goldman > Kafka Streams should support self-join on

[jira] [Commented] (KAFKA-7484) Fix test SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown()

[ https://issues.apache.org/jira/browse/KAFKA-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084261#comment-17084261 ] Sophie Blee-Goldman commented on KAFKA-7484: Oh actually, the recent failure was on the

[jira] [Resolved] (KAFKA-7484) Fix test SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown()

[ https://issues.apache.org/jira/browse/KAFKA-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-7484. Resolution: Fixed > Fix test >

[jira] [Reopened] (KAFKA-7484) Fix test SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown()

[ https://issues.apache.org/jira/browse/KAFKA-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-7484: failed on a PR with h3. Stacktrace java.lang.RuntimeException:

[jira] [Created] (KAFKA-9875) Flaky Test SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown[exactly_once]

Sophie Blee-Goldman created KAFKA-9875: -- Summary: Flaky Test SuppressionDurabilityIntegrationTest.shouldRecoverBufferAfterShutdown[exactly_once] Key: KAFKA-9875 URL:

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084263#comment-17084263 ] Sophie Blee-Goldman commented on KAFKA-7965: h3. Error Message

[jira] [Commented] (KAFKA-9972) Corrupted standby task could be committed

[ https://issues.apache.org/jira/browse/KAFKA-9972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17103577#comment-17103577 ] Sophie Blee-Goldman commented on KAFKA-9972: Not exactly, I was proposing to remove the

[jira] [Created] (KAFKA-9983) Add end-to-end latency metrics to Streams

Sophie Blee-Goldman created KAFKA-9983: -- Summary: Add end-to-end latency metrics to Streams Key: KAFKA-9983 URL: https://issues.apache.org/jira/browse/KAFKA-9983 Project: Kafka Issue

[jira] [Commented] (KAFKA-9013) Flaky Test MirrorConnectorsIntegrationTest#testReplication

[ https://issues.apache.org/jira/browse/KAFKA-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105958#comment-17105958 ] Sophie Blee-Goldman commented on KAFKA-9013:

[jira] [Commented] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

[ https://issues.apache.org/jira/browse/KAFKA-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105950#comment-17105950 ] Sophie Blee-Goldman commented on KAFKA-9897: [~guozhang] recently improved the integration

[jira] [Updated] (KAFKA-9987) Add new cooperative assignor optimized for constant-subscription group

[ https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9987: --- Summary: Add new cooperative assignor optimized for constant-subscription group

[jira] [Created] (KAFKA-9987) Add new cooperative assignor optimized for constant-subscription. group

Sophie Blee-Goldman created KAFKA-9987: -- Summary: Add new cooperative assignor optimized for constant-subscription. group Key: KAFKA-9987 URL: https://issues.apache.org/jira/browse/KAFKA-9987

[jira] [Resolved] (KAFKA-4969) State-store workload-aware StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-4969. Fix Version/s: (was: 1.1.0) 2.6.0 Resolution: Fixed

[jira] [Resolved] (KAFKA-8207) StickyPartitionAssignor for KStream

[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8207. Resolution: Not A Problem Closing this as "Not a Problem" as the partition

[jira] [Resolved] (KAFKA-8858) Kafka Streams - Failed to Rebalance Error and stream consumer stuck for some reason

[ https://issues.apache.org/jira/browse/KAFKA-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8858. Assignee: Guozhang Wang Resolution: Duplicate > Kafka Streams - Failed to

[jira] [Resolved] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9112. Fix Version/s: 2.6.0 Assignee: Guozhang Wang Resolution: Fixed

[jira] [Resolved] (KAFKA-6063) StreamsException is thrown after the changing `partitions`

[ https://issues.apache.org/jira/browse/KAFKA-6063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-6063. Resolution: Not A Problem > StreamsException is thrown after the changing

[jira] [Commented] (KAFKA-9921) Caching is not working properly with WindowStateStore when retaining duplicates

[ https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17101130#comment-17101130 ] Sophie Blee-Goldman commented on KAFKA-9921: Thanks for the reminder, just opened [this small

[jira] [Assigned] (KAFKA-4696) Streams standby task assignment should be state-store aware

[ https://issues.apache.org/jira/browse/KAFKA-4696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-4696: -- Fix Version/s: 2.6.0 Assignee: Sophie Blee-Goldman (was: Richard Yu)

[jira] [Created] (KAFKA-9991) Flaky Test KTableSourceTopicRestartIntegrationTest.shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosAlphaEnabled

Sophie Blee-Goldman created KAFKA-9991: -- Summary: Flaky Test KTableSourceTopicRestartIntegrationTest.shouldRestoreAndProgressWhenTopicWrittenToDuringRestorationWithEosAlphaEnabled Key: KAFKA-9991 URL:

[jira] [Updated] (KAFKA-9987) Improve sticky partition assignor algorithm

[ https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9987: --- Description: In 

[jira] [Updated] (KAFKA-9987) Improve sticky partition assignor algorithm

[ https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9987: --- Summary: Improve sticky partition assignor algorithm (was: Add new cooperative

[jira] [Commented] (KAFKA-9989) StreamsUpgradeTest.test_metadata_upgrade could not guarantee all processor gets assigned task

[ https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106744#comment-17106744 ] Sophie Blee-Goldman commented on KAFKA-9989: Yeah it would be good to dive into why this is

[jira] [Assigned] (KAFKA-9132) Refactor StreamThread to take advantage of new ConsumerRebalanceListener exception handling

[ https://issues.apache.org/jira/browse/KAFKA-9132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9132: -- Assignee: Boyang Chen > Refactor StreamThread to take advantage of new

[jira] [Resolved] (KAFKA-9132) Refactor StreamThread to take advantage of new ConsumerRebalanceListener exception handling

[ https://issues.apache.org/jira/browse/KAFKA-9132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9132. Fix Version/s: 2.6.0 Resolution: Fixed > Refactor StreamThread to take

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

[ https://issues.apache.org/jira/browse/KAFKA-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8174. Resolution: Won't Do > Can't call arbitrary SimpleBenchmarks tests from >

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

[ https://issues.apache.org/jira/browse/KAFKA-8174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108456#comment-17108456 ] Sophie Blee-Goldman commented on KAFKA-8174: Marking this resolved as "irrelevant" since we

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

[ https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108449#comment-17108449 ] Sophie Blee-Goldman commented on KAFKA-7912: I set the fix version to 2.3.0 rather than

[jira] [Resolved] (KAFKA-9521) Flaky Test DeleteConsumerGroupsTest#testDeleteCmdEmptyGroup

[ https://issues.apache.org/jira/browse/KAFKA-9521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9521. Resolution: Duplicate > Flaky Test

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

[ https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-7912: --- Fix Version/s: 2.4.0 2.3.1 > In-memory key-value store does not

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

[ https://issues.apache.org/jira/browse/KAFKA-7912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-7912: --- Fix Version/s: (was: 2.3.1) 2.3.0 > In-memory key-value store

[jira] [Resolved] (KAFKA-9001) Flaky Test KStreamAggregationIntegrationTest#shouldReduceSessionWindows

[ https://issues.apache.org/jira/browse/KAFKA-9001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9001. Resolution: Cannot Reproduce > Flaky Test

[jira] [Commented] (KAFKA-9989) StreamsUpgradeTest.test_metadata_upgrade could not guarantee all processor gets assigned task

[ https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108459#comment-17108459 ] Sophie Blee-Goldman commented on KAFKA-9989: Since this was due to an actual bug in the

[jira] [Commented] (KAFKA-9989) StreamsUpgradeTest.test_metadata_upgrade could not guarantee all processor gets assigned task

[ https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106864#comment-17106864 ] Sophie Blee-Goldman commented on KAFKA-9989: Yeah that looks like the

[jira] [Commented] (KAFKA-9987) Improve sticky partition assignor algorithm

[ https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106832#comment-17106832 ] Sophie Blee-Goldman commented on KAFKA-9987: Pseudo-code sketch of the algorithm: {{C_f :=

[jira] [Created] (KAFKA-10006) Streams should not attempt to create internal topics that may exist

Sophie Blee-Goldman created KAFKA-10006: --- Summary: Streams should not attempt to create internal topics that may exist Key: KAFKA-10006 URL: https://issues.apache.org/jira/browse/KAFKA-10006

[jira] [Commented] (KAFKA-9987) Improve sticky partition assignor algorithm

[ https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108726#comment-17108726 ] Sophie Blee-Goldman commented on KAFKA-9987: [~hai_lin] We can definitely backport this to

[jira] [Commented] (KAFKA-9987) Improve sticky partition assignor algorithm

[ https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108731#comment-17108731 ] Sophie Blee-Goldman commented on KAFKA-9987: [~twmb] in your "Existing" benchmarks did you

[jira] [Commented] (KAFKA-9987) Improve sticky partition assignor algorithm

[ https://issues.apache.org/jira/browse/KAFKA-9987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108718#comment-17108718 ] Sophie Blee-Goldman commented on KAFKA-9987: [~twmb] exactly, this only works for the

[jira] [Commented] (KAFKA-10008) Symbol not found when running Kafka Streams with RocksDB dependency on MacOS 10.13.6

[ https://issues.apache.org/jira/browse/KAFKA-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108754#comment-17108754 ] Sophie Blee-Goldman commented on KAFKA-10008: - Yeah...it's a pretty huge bummer to be

[jira] [Created] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]

Sophie Blee-Goldman created KAFKA-10017: --- Summary: Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true] Key: KAFKA-10017 URL: https://issues.apache.org/jira/browse/KAFKA-10017

[jira] [Commented] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110633#comment-17110633 ] Sophie Blee-Goldman commented on KAFKA-10017: - h3. Stacktrace java.lang.AssertionError: Did

[jira] [Comment Edited] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110633#comment-17110633 ] Sophie Blee-Goldman edited comment on KAFKA-10017 at 5/18/20, 9:36 PM:

[jira] [Updated] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10017: Description: Creating a new ticket for this since the root cause is different

[jira] [Updated] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10017: Summary: Flaky Test

[jira] [Commented] (KAFKA-10010) Should close standby task for safety during HandleLostAll

[ https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110518#comment-17110518 ] Sophie Blee-Goldman commented on KAFKA-10010: - It's possible the active <-> standby task

[jira] [Commented] (KAFKA-10010) Should close standby task for safety during HandleLostAll

[ https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110522#comment-17110522 ] Sophie Blee-Goldman commented on KAFKA-10010: - When I first started looking into the store

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

[ https://issues.apache.org/jira/browse/KAFKA-6579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17110508#comment-17110508 ] Sophie Blee-Goldman commented on KAFKA-6579: No, I looked into it but the scope its

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

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

<    1   2   3   4   5   6   7   8   9   10   >