[jira] [Updated] (KAFKA-9821) Stream task may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9821: --- Labels: (was: need-kip) > Stream task may skip assignment with static members and

[jira] [Updated] (KAFKA-9821) Stream task may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9821: --- Summary: Stream task may skip assignment with static members and incremental

[jira] [Updated] (KAFKA-10078) Stream tasks may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10078: Component/s: (was: streams) consumer > Stream tasks may skip

[jira] [Assigned] (KAFKA-9821) Stream task may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9821: -- Assignee: Sophie Blee-Goldman > Stream task may skip assignment with static

[jira] [Updated] (KAFKA-9821) Stream task may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9821: --- Fix Version/s: 2.6.0 > Stream task may skip assignment with static members and

[jira] [Updated] (KAFKA-9821) Stream task may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9821: --- Component/s: (was: consumer) streams > Stream task may skip

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

[ https://issues.apache.org/jira/browse/KAFKA-10078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10078: Summary: Partition may skip assignment with static members and incremental

[jira] [Updated] (KAFKA-9821) Stream task may skip assignment with static members and incremental rebalances

[ https://issues.apache.org/jira/browse/KAFKA-9821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9821: --- Affects Version/s: 2.4.0 > Stream task may skip assignment with static members and

[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=17121378#comment-17121378 ] Sophie Blee-Goldman commented on KAFKA-9987: Not as far as I know. It should be in the

[jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121356#comment-17121356 ] Sophie Blee-Goldman commented on KAFKA-9148: Unfortunately we still haven't been able to

[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=17116943#comment-17116943 ] Sophie Blee-Goldman commented on KAFKA-9821: This issue is fixed for Streams in 2.6.0 by

[jira] [Created] (KAFKA-10085) Compute lag correctly for optimized source changelogs

Sophie Blee-Goldman created KAFKA-10085: --- Summary: Compute lag correctly for optimized source changelogs Key: KAFKA-10085 URL: https://issues.apache.org/jira/browse/KAFKA-10085 Project: Kafka

[jira] [Resolved] (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 resolved KAFKA-9987. Fix Version/s: 2.5.1 2.4.2 2.6.0

[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: --- Component/s: consumer > Improve sticky partition assignor algorithm >

[jira] [Commented] (KAFKA-10633) Constant probing rebalances in Streams 2.6

[ https://issues.apache.org/jira/browse/KAFKA-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219859#comment-17219859 ] A. Sophie Blee-Goldman commented on KAFKA-10633: I'm like 99% sure this will turn out to

[jira] [Commented] (KAFKA-10633) Constant probing rebalances in Streams 2.6

[ https://issues.apache.org/jira/browse/KAFKA-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219861#comment-17219861 ] A. Sophie Blee-Goldman commented on KAFKA-10633: A thread should always reset its

[jira] [Commented] (KAFKA-10633) Constant probing rebalances in Streams 2.6

[ https://issues.apache.org/jira/browse/KAFKA-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17219963#comment-17219963 ] A. Sophie Blee-Goldman commented on KAFKA-10633: The issue with directory contents being

[jira] [Created] (KAFKA-10651) Assignor reports offsets from uninitialized task

A. Sophie Blee-Goldman created KAFKA-10651: -- Summary: Assignor reports offsets from uninitialized task Key: KAFKA-10651 URL: https://issues.apache.org/jira/browse/KAFKA-10651 Project: Kafka

[jira] [Updated] (KAFKA-10651) Assignor reports offsets from uninitialized task

[ https://issues.apache.org/jira/browse/KAFKA-10651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-10651: --- Description: In KIP-441, the new HA assignor makes an informed decision

[jira] [Assigned] (KAFKA-10651) Assignor reports offsets from uninitialized task

[ https://issues.apache.org/jira/browse/KAFKA-10651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reassigned KAFKA-10651: -- Assignee: A. Sophie Blee-Goldman > Assignor reports offsets from

[jira] [Reopened] (KAFKA-9161) Close gaps in Streams configs documentation

[ https://issues.apache.org/jira/browse/KAFKA-9161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9161: > Close gaps in Streams configs documentation >

[jira] [Commented] (KAFKA-10366) TimeWindowedDeserializer doesn't allow users to set a custom window size

[ https://issues.apache.org/jira/browse/KAFKA-10366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17172633#comment-17172633 ] Sophie Blee-Goldman commented on KAFKA-10366: - Yeah, there are two related problems. The

[jira] [Updated] (KAFKA-10362) When resuming Streams active task with EOS, the checkpoint file should be deleted

[ https://issues.apache.org/jira/browse/KAFKA-10362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10362: Affects Version/s: 2.6.0 > When resuming Streams active task with EOS, the

[jira] [Commented] (KAFKA-10357) Handle accidental deletion of repartition-topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17174986#comment-17174986 ] Sophie Blee-Goldman commented on KAFKA-10357: - How are we going to handle

[jira] [Commented] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175905#comment-17175905 ] Sophie Blee-Goldman commented on KAFKA-10284: - [~bchen225242] [~hachikuji] Is this a

[jira] [Commented] (KAFKA-10186) Aborting transaction with pending data should throw non-fatal exception

[ https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171078#comment-17171078 ] Sophie Blee-Goldman commented on KAFKA-10186: - [~nym3r0s] You need to send an email to the

[jira] [Commented] (KAFKA-10186) Aborting transaction with pending data should throw non-fatal exception

[ https://issues.apache.org/jira/browse/KAFKA-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171026#comment-17171026 ] Sophie Blee-Goldman commented on KAFKA-10186: - I was suggesting to throw a new exception,

[jira] [Commented] (KAFKA-10336) Rolling upgrade with Suppression AND Standbys may throw exceptions

[ https://issues.apache.org/jira/browse/KAFKA-10336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17169038#comment-17169038 ] Sophie Blee-Goldman commented on KAFKA-10336: - Thanks for the detailed bug report. Quick

[jira] [Commented] (KAFKA-10137) Clean-up retain Duplicate logic in Window Stores

[ https://issues.apache.org/jira/browse/KAFKA-10137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17169045#comment-17169045 ] Sophie Blee-Goldman commented on KAFKA-10137: - Yeah I thought that might be the case,

[jira] [Updated] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10395: Labels: needs-kip test-framework (was: test-framework) > TopologyTestDriver does

[jira] [Assigned] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-10395: --- Assignee: Sophie Blee-Goldman > TopologyTestDriver does not work with

[jira] [Commented] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176675#comment-17176675 ] Sophie Blee-Goldman commented on KAFKA-10395: - The only really holistic solution I can think

[jira] [Commented] (KAFKA-10357) Handle accidental deletion of repartition-topics as exceptional failure

[ https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176535#comment-17176535 ] Sophie Blee-Goldman commented on KAFKA-10357: - I think the elegant way to shutdown the whole

[jira] [Updated] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10284: Priority: Critical (was: Major) > Group membership update due to static member

[jira] [Updated] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10395: Labels: test-framework (was: needs-kip test-framework) > TopologyTestDriver does

[jira] [Comment Edited] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176665#comment-17176665 ] Sophie Blee-Goldman edited comment on KAFKA-10395 at 8/13/20, 12:36 AM:

[jira] [Updated] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10395: Labels: test-framework (was: ) > TopologyTestDriver does not work with dynamic

[jira] [Created] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

Sophie Blee-Goldman created KAFKA-10395: --- Summary: TopologyTestDriver does not work with dynamic topic routing Key: KAFKA-10395 URL: https://issues.apache.org/jira/browse/KAFKA-10395 Project:

[jira] [Comment Edited] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176665#comment-17176665 ] Sophie Blee-Goldman edited comment on KAFKA-10395 at 8/13/20, 12:41 AM:

[jira] [Updated] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10284: Fix Version/s: (was: 2.6.1) > Group membership update due to static member

[jira] [Commented] (KAFKA-10395) TopologyTestDriver does not work with dynamic topic routing

[ https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176665#comment-17176665 ] Sophie Blee-Goldman commented on KAFKA-10395: - I think we could just modify the

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

[ https://issues.apache.org/jira/browse/KAFKA-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17169187#comment-17169187 ] Sophie Blee-Goldman commented on KAFKA-8159: A related bummer is that you can't do fetches

[jira] [Commented] (KAFKA-9062) Handle stalled writes to RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17149530#comment-17149530 ] Sophie Blee-Goldman commented on KAFKA-9062:  [~thebearmayor] I think you could be hitting 

[jira] [Commented] (KAFKA-9062) Handle stalled writes to RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17149532#comment-17149532 ] Sophie Blee-Goldman commented on KAFKA-9062: Sorry, I didn't actually answer your question.

[jira] [Commented] (KAFKA-10166) Excessive TaskCorruptedException seen in testing

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17152208#comment-17152208 ] Sophie Blee-Goldman commented on KAFKA-10166: - [~rhauch] I think we can get it merged

[jira] [Assigned] (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 reassigned KAFKA-10017: --- Assignee: Sophie Blee-Goldman (was: Matthias J. Sax) > Flaky Test

[jira] [Commented] (KAFKA-10156) Flaky Test SslSelectorTest.testCloseOldestConnection

[ https://issues.apache.org/jira/browse/KAFKA-10156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17156944#comment-17156944 ] Sophie Blee-Goldman commented on KAFKA-10156: - Hey [~serj567], thanks for picking this up!

[jira] [Reopened] (KAFKA-10166) Excessive TaskCorruptedException seen in testing

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-10166: - Assignee: (was: Bruno Cadonna) Found two edge cases we missed earlier so

[jira] [Commented] (KAFKA-10262) StateDirectory is not thread-safe

[ https://issues.apache.org/jira/browse/KAFKA-10262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155773#comment-17155773 ] Sophie Blee-Goldman commented on KAFKA-10262: - I think we can just do something like 

[jira] [Comment Edited] (KAFKA-10262) StateDirectory is not thread-safe

[ https://issues.apache.org/jira/browse/KAFKA-10262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17155773#comment-17155773 ] Sophie Blee-Goldman edited comment on KAFKA-10262 at 7/10/20, 10:17 PM:

[jira] [Created] (KAFKA-10262) StateDirectory is not thread-safe

Sophie Blee-Goldman created KAFKA-10262: --- Summary: StateDirectory is not thread-safe Key: KAFKA-10262 URL: https://issues.apache.org/jira/browse/KAFKA-10262 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-10217) Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics

[ https://issues.apache.org/jira/browse/KAFKA-10217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148994#comment-17148994 ] Sophie Blee-Goldman commented on KAFKA-10217: - [~mhmdchebbi] try rebasing – the PR that

[jira] [Updated] (KAFKA-6508) Look into optimizing StreamPartitionAssignor StandbyTask Assignment

[ https://issues.apache.org/jira/browse/KAFKA-6508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-6508: --- Fix Version/s: 2.6.0 > Look into optimizing StreamPartitionAssignor StandbyTask

[jira] [Resolved] (KAFKA-6508) Look into optimizing StreamPartitionAssignor StandbyTask Assignment

[ https://issues.apache.org/jira/browse/KAFKA-6508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-6508. Resolution: Fixed This should be addressed via KIP-441 > Look into optimizing

[jira] [Created] (KAFKA-10249) In-memory stores are skipped when checkpointing but not skipped when reading the checkpoint

Sophie Blee-Goldman created KAFKA-10249: --- Summary: In-memory stores are skipped when checkpointing but not skipped when reading the checkpoint Key: KAFKA-10249 URL:

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

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17152370#comment-17152370 ] Sophie Blee-Goldman commented on KAFKA-10017: - The local runs just completed successfully so

[jira] [Resolved] (KAFKA-10191) fix flaky StreamsOptimizedTest

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

[jira] [Updated] (KAFKA-10191) fix flaky StreamsOptimizedTest

[ https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10191: Fix Version/s: 2.7.0 > fix flaky StreamsOptimizedTest >

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

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17152909#comment-17152909 ] Sophie Blee-Goldman commented on KAFKA-10017: - Hey [~dima5rr] This test assumes only one

[jira] [Commented] (KAFKA-10251) Flaky Test kafka.api.TransactionsBounceTest.testWithGroupMetadata

[ https://issues.apache.org/jira/browse/KAFKA-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17154110#comment-17154110 ] Sophie Blee-Goldman commented on KAFKA-10251: - cc [~bchen225242] – 

[jira] [Created] (KAFKA-10251) Flaky Test kafka.api.TransactionsBounceTest.testWithGroupMetadata

Sophie Blee-Goldman created KAFKA-10251: --- Summary: Flaky Test kafka.api.TransactionsBounceTest.testWithGroupMetadata Key: KAFKA-10251 URL: https://issues.apache.org/jira/browse/KAFKA-10251

[jira] [Commented] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

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

[jira] [Created] (KAFKA-10264) Flaky Test TransactionsTest.testBumpTransactionalEpoch

Sophie Blee-Goldman created KAFKA-10264: --- Summary: Flaky Test TransactionsTest.testBumpTransactionalEpoch Key: KAFKA-10264 URL: https://issues.apache.org/jira/browse/KAFKA-10264 Project: Kafka

[jira] [Commented] (KAFKA-10255) Fix flaky testOneWayReplicationWithAutorOffsetSync1 test

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

[jira] [Updated] (KAFKA-10262) StateDirectory is not thread-safe

[ https://issues.apache.org/jira/browse/KAFKA-10262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10262: Description: As explicitly stated in the StateDirectory javadocs,  "This class is

[jira] [Created] (KAFKA-10165) Percentiles metric leaking memory

Sophie Blee-Goldman created KAFKA-10165: --- Summary: Percentiles metric leaking memory Key: KAFKA-10165 URL: https://issues.apache.org/jira/browse/KAFKA-10165 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-10166) Excessive TaskCorruptedException seen in test applications

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

[jira] [Updated] (KAFKA-10166) Excessive TaskCorruptedException seen in test applications

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10166: Summary: Excessive TaskCorruptedException seen in test applications (was:

[jira] [Updated] (KAFKA-10166) Excessive TaskCorruptedException seen in testing

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10166: Summary: Excessive TaskCorruptedException seen in testing (was: Excessive

[jira] [Assigned] (KAFKA-10166) Excessive TaskCorruptedException seen in test applications

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-10166: --- Assignee: Sophie Blee-Goldman > Excessive TaskCorruptedException seen in

[jira] [Updated] (KAFKA-10166) Excessive TaskCorruptedException seen in test applications

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10166: Description: As the title indicates. Seen occasionally with ALOS (~20 times in

[jira] [Updated] (KAFKA-10166) Excessive TaskCorruptedException seen in testing

[ https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10166: Description: As the title indicates, long-running test applications with injected

[jira] [Created] (KAFKA-10166) Excessive TaskCorruptedException seen in soak

Sophie Blee-Goldman created KAFKA-10166: --- Summary: Excessive TaskCorruptedException seen in soak Key: KAFKA-10166 URL: https://issues.apache.org/jira/browse/KAFKA-10166 Project: Kafka

[jira] [Updated] (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 updated KAFKA-5636: --- Labels: needs-kip (was: ) > Add Sliding-Window support for Aggregations >

[jira] [Updated] (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 updated KAFKA-5636: --- Priority: Major (was: Minor) > Add Sliding-Window support for Aggregations >

[jira] [Created] (KAFKA-10169) KafkaException: Failing batch since transaction was aborted

Sophie Blee-Goldman created KAFKA-10169: --- Summary: KafkaException: Failing batch since transaction was aborted Key: KAFKA-10169 URL: https://issues.apache.org/jira/browse/KAFKA-10169 Project:

[jira] [Commented] (KAFKA-10169) KafkaException: Failing batch since transaction was aborted

[ https://issues.apache.org/jira/browse/KAFKA-10169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136255#comment-17136255 ] Sophie Blee-Goldman commented on KAFKA-10169: - I haven't seen anything damning (or even

[jira] [Reopened] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

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

[jira] [Updated] (KAFKA-9983) Add INFO-level end-to-end latency metrics to Streams

[ https://issues.apache.org/jira/browse/KAFKA-9983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9983: --- Description: Min and max task-level metrics exposed on all source and terminal nodes

[jira] [Updated] (KAFKA-9983) Add INFO-level end-to-end latency metrics to Streams

[ https://issues.apache.org/jira/browse/KAFKA-9983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9983: --- Description: Min and max task-level metrics exposed for all source and terminal

[jira] [Resolved] (KAFKA-10151) Flaky Test StoreUpgradeIntegrationTest.shouldMigratePersistentKeyValueStoreToTimestampedKeyValueStoreUsingPapi

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

[jira] [Commented] (KAFKA-10151) Flaky Test StoreUpgradeIntegrationTest.shouldMigratePersistentKeyValueStoreToTimestampedKeyValueStoreUsingPapi

[ https://issues.apache.org/jira/browse/KAFKA-10151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138677#comment-17138677 ] Sophie Blee-Goldman commented on KAFKA-10151: - Huh, I didn't even notice that bug. It's just

[jira] [Reopened] (KAFKA-9974) Flaky Test OptimizedKTableIntegrationTest#shouldApplyUpdatesToStandbyStore

[ https://issues.apache.org/jira/browse/KAFKA-9974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-9974: Unfortunately this just failed again, at a different place: h3. Stacktrace

[jira] [Commented] (KAFKA-10155) Flaky Test ReassignPartitionsUnitTest.testModifyBrokerThrottles

[ https://issues.apache.org/jira/browse/KAFKA-10155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17138843#comment-17138843 ] Sophie Blee-Goldman commented on KAFKA-10155: - The fix was only merged 6 hours ago. Did it

[jira] [Commented] (KAFKA-10184) Flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores

[ https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17139543#comment-17139543 ] Sophie Blee-Goldman commented on KAFKA-10184: - Yeah, it's failing on the setup and hasn't

[jira] [Commented] (KAFKA-10005) Decouple RestoreListener from RestoreCallback and not enable bulk loading for RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-10005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17139916#comment-17139916 ] Sophie Blee-Goldman commented on KAFKA-10005: - I've been thinking about this lately and I'm

[jira] [Commented] (KAFKA-10184) Flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores

[ https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17139546#comment-17139546 ] Sophie Blee-Goldman commented on KAFKA-10184: - [~vvcephei] Could we maybe do something like

[jira] [Commented] (KAFKA-10184) Flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores

[ https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17139548#comment-17139548 ] Sophie Blee-Goldman commented on KAFKA-10184: - Or instead (or in addition to the above)

[jira] [Commented] (KAFKA-10191) fix flaky StreamsOptimizedTest

[ https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142361#comment-17142361 ] Sophie Blee-Goldman commented on KAFKA-10191: - Awesome, thanks Jun. I think the hypothesis

[jira] [Commented] (KAFKA-10105) Regression in group coordinator dealing with flaky clients joining while leaving

[ https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142478#comment-17142478 ] Sophie Blee-Goldman commented on KAFKA-10105: - It's possible. If you're able to reproduce

[jira] [Commented] (KAFKA-8416) Improve Documentation for Enabling Optimizations

[ https://issues.apache.org/jira/browse/KAFKA-8416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142577#comment-17142577 ] Sophie Blee-Goldman commented on KAFKA-8416: Hey [~bbejeck], I saw that this is [documented

[jira] [Updated] (KAFKA-8416) Improve Documentation for Enabling Optimizations

[ https://issues.apache.org/jira/browse/KAFKA-8416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8416: --- Labels: newbie (was: newbie,) > Improve Documentation for Enabling Optimizations >

[jira] [Updated] (KAFKA-10191) fix flaky StreamsOptimizedTest

[ https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10191: Priority: Major (was: Blocker) > fix flaky StreamsOptimizedTest >

[jira] [Assigned] (KAFKA-4996) Fix findbugs multithreaded correctness warnings for streams

[ https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-4996: -- Assignee: Sophie Blee-Goldman > Fix findbugs multithreaded correctness

[jira] [Updated] (KAFKA-10191) fix flaky StreamsOptimizedTest

[ https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-10191: Fix Version/s: (was: 2.6.0) > fix flaky StreamsOptimizedTest >

[jira] [Commented] (KAFKA-10191) fix flaky StreamsOptimizedTest

[ https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142567#comment-17142567 ] Sophie Blee-Goldman commented on KAFKA-10191: - Awesome! That said, I want to qualify my

[jira] [Comment Edited] (KAFKA-4996) Fix findbugs multithreaded correctness warnings for streams

[ https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142592#comment-17142592 ] Sophie Blee-Goldman edited comment on KAFKA-4996 at 6/23/20, 3:32 AM:

[jira] [Commented] (KAFKA-4996) Fix findbugs multithreaded correctness warnings for streams

[ https://issues.apache.org/jira/browse/KAFKA-4996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142592#comment-17142592 ] Sophie Blee-Goldman commented on KAFKA-4996: Took a quick look at removing the spotBugs rule

[jira] [Commented] (KAFKA-10068) Verify HighAvailabilityTaskAssignor performance with large clusters and topologies

[ https://issues.apache.org/jira/browse/KAFKA-10068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142613#comment-17142613 ] Sophie Blee-Goldman commented on KAFKA-10068: - Hey [~vvcephei], WDYT about demoting this now

[jira] [Commented] (KAFKA-10191) fix flaky StreamsOptimizedTest - call KafkaStreams#cleanUp before starting the application up the second time

[ https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143105#comment-17143105 ] Sophie Blee-Goldman commented on KAFKA-10191: - Cool. Since this is failing pretty regularly,

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