[jira] [Assigned] (KAFKA-9003) Flaky Test RepartitionOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED

2019-10-08 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9003: -- Assignee: Sophie Blee-Goldman > Flaky Test >

[jira] [Assigned] (KAFKA-8743) Flaky Test RepartitionWithMergeOptimizingIntegrationTest#shouldSendCorrectRecords_OPTIMIZED

2019-10-08 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-8743: -- Assignee: Sophie Blee-Goldman > Flaky Test >

[jira] [Updated] (KAFKA-8948) Flaky Test StreamsEosTest#test_rebalance_complex is broken for multiple runs

2019-10-09 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8948: --- Summary: Flaky Test StreamsEosTest#test_rebalance_complex is broken for multiple

[jira] [Updated] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

2019-10-09 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-4222: --- Labels: flaky-test (was: ) > Transient failure in

[jira] [Updated] (KAFKA-4222) Flaky Test QueryableStateIntegrationTest.queryOnRebalance

2019-10-09 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-4222: --- Summary: Flaky Test QueryableStateIntegrationTest.queryOnRebalance (was: Transient

[jira] [Commented] (KAFKA-9006) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues

2019-10-09 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947864#comment-16947864 ] Sophie Blee-Goldman commented on KAFKA-9006: Adding this to the high priority list due to

[jira] [Commented] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector

2019-10-03 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943989#comment-16943989 ] Sophie Blee-Goldman commented on KAFKA-8555: FAILED {code:java}

[jira] [Comment Edited] (KAFKA-8970) StateDirectory creation fails with Exception

2019-10-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944889#comment-16944889 ] Sophie Blee-Goldman edited comment on KAFKA-8970 at 10/5/19 12:19 AM:

[jira] [Updated] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0

2019-10-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8649: --- Affects Version/s: 2.1.0 2.2.0 2.3.0 >

[jira] [Resolved] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0

2019-10-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8649. Fix Version/s: 2.3.1 2.4.0 Resolution: Fixed > Error

[jira] [Commented] (KAFKA-8970) StateDirectory creation fails with Exception

2019-10-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944889#comment-16944889 ] Sophie Blee-Goldman commented on KAFKA-8970: Ah ok, thanks for clarifying! I agree it

[jira] [Commented] (KAFKA-8970) StateDirectory creation fails with Exception

2019-10-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944931#comment-16944931 ] Sophie Blee-Goldman commented on KAFKA-8970: Actually I just checked the code and I believe

[jira] [Commented] (KAFKA-8970) StateDirectory creation fails with Exception

2019-10-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944835#comment-16944835 ] Sophie Blee-Goldman commented on KAFKA-8970: What is the motivation for running two instances

[jira] [Commented] (KAFKA-8970) StateDirectory creation fails with Exception

2019-10-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944838#comment-16944838 ] Sophie Blee-Goldman commented on KAFKA-8970: Maybe it would be better to explicitly not allow

[jira] [Created] (KAFKA-8987) Allow IQ on restored state stores while others are still restoring

2019-10-04 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-8987: -- Summary: Allow IQ on restored state stores while others are still restoring Key: KAFKA-8987 URL: https://issues.apache.org/jira/browse/KAFKA-8987

[jira] [Commented] (KAFKA-8973) Give user options to turn off linger.ms/batch.size constraint

2019-10-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944777#comment-16944777 ] Sophie Blee-Goldman commented on KAFKA-8973: If users want to opt-out of either, can't they

[jira] [Commented] (KAFKA-9006) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues

2019-10-11 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949819#comment-16949819 ] Sophie Blee-Goldman commented on KAFKA-9006: Not sure if this counts as a failure or not,

[jira] [Updated] (KAFKA-9032) Serializer is invoked with null when foreignValue=null

2019-10-11 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9032: --- Priority: Blocker (was: Major) > Serializer is invoked with null when

[jira] [Updated] (KAFKA-9032) Serializer is invoked with null when foreignValue=null

2019-10-11 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9032: --- Fix Version/s: 2.4.0 > Serializer is invoked with null when foreignValue=null >

[jira] [Updated] (KAFKA-5566) Flaky Test QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied

2019-10-11 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-5566: --- Summary: Flaky Test QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied

[jira] [Commented] (KAFKA-9032) Serializer is invoked with null when foreignValue=null

2019-10-11 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949841#comment-16949841 ] Sophie Blee-Goldman commented on KAFKA-9032: [~abellemare] [~vvcephei] Can you take a look?

[jira] [Updated] (KAFKA-9022) Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues

2019-10-11 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9022: --- Description: array lengths differed, expected.length=2 actual.length=1; arrays first

[jira] [Commented] (KAFKA-9022) Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues

2019-10-11 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949839#comment-16949839 ] Sophie Blee-Goldman commented on KAFKA-9022: Assigning this to [~vvcephei] since he's already

[jira] [Assigned] (KAFKA-9022) Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues

2019-10-11 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9022: -- Assignee: John Roesler > Flaky Test

[jira] [Resolved] (KAFKA-9020) Streams sub-topologies should be sorted by sink -> source relationship

2019-10-14 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9020. Fix Version/s: 2.4.0 Resolution: Fixed > Streams sub-topologies should be

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

2019-12-18 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16999467#comment-16999467 ] Sophie Blee-Goldman commented on KAFKA-9062: [~jpzk] I agree this is a bug in Streams (that's

[jira] [Created] (KAFKA-9323) Refactor Streams' upgrade system tests

2019-12-20 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9323: -- Summary: Refactor Streams' upgrade system tests Key: KAFKA-9323 URL: https://issues.apache.org/jira/browse/KAFKA-9323 Project: Kafka Issue

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

2019-12-20 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17001259#comment-17001259 ] Sophie Blee-Goldman commented on KAFKA-9062: Just to clarify, the "simple workaround"

[jira] [Updated] (KAFKA-8897) Increase Version of RocksDB

2020-02-10 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8897: --- Fix Version/s: 3.0.0 > Increase Version of RocksDB > --- > >

[jira] [Updated] (KAFKA-9450) Decouple inner state flushing from committing

2020-02-10 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9450: --- Description: When EOS is turned on, the commit interval is set quite low (100ms) and

[jira] [Updated] (KAFKA-8897) Increase Version of RocksDB

2020-02-10 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8897: --- Priority: Blocker (was: Major) > Increase Version of RocksDB >

[jira] [Updated] (KAFKA-9450) Decouple inner state flushing from committing

2020-02-10 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9450: --- Summary: Decouple inner state flushing from committing (was: Decouple inner state

[jira] [Commented] (KAFKA-9450) Decouple inner state flushing from committing with EOS

2020-02-10 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033915#comment-17033915 ] Sophie Blee-Goldman commented on KAFKA-9450: [~NaviBrar] I assume that was only merged into

[jira] [Comment Edited] (KAFKA-8037) KTable restore may load bad data

2020-02-12 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034746#comment-17034746 ] Sophie Blee-Goldman edited comment on KAFKA-8037 at 2/12/20 5:38 PM: -

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

2020-02-12 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17035541#comment-17035541 ] Sophie Blee-Goldman commented on KAFKA-8037: Ha, yes good catch I'll fix the typo in 2)

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

2020-02-25 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044774#comment-17044774 ] Sophie Blee-Goldman commented on KAFKA-9603: Hey [~biljazovic], can you tell if this happened

[jira] [Commented] (KAFKA-8784) Remove default implementation of RocksDBConfigSetter#close

2020-02-28 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17048177#comment-17048177 ] Sophie Blee-Goldman commented on KAFKA-8784: [~sbellapu] we actually can't implement this

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

2020-02-26 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046169#comment-17046169 ] Sophie Blee-Goldman commented on KAFKA-9603: Admittedly a day does seem like a long time, but

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

2020-02-26 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046170#comment-17046170 ] Sophie Blee-Goldman commented on KAFKA-9603: Do you notice that some of the task directories,

[jira] [Commented] (KAFKA-9620) Task revocation failure could introduce remaining unclean tasks

2020-02-27 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047176#comment-17047176 ] Sophie Blee-Goldman commented on KAFKA-9620: [~guozhang] I agree with your second

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

2020-03-05 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9664: -- Summary: Flaky Test KafkaStreamsTest#testStateThreadClose Key: KAFKA-9664 URL: https://issues.apache.org/jira/browse/KAFKA-9664 Project: Kafka

[jira] [Commented] (KAFKA-9637) Create separate state directory to manage locks

2020-03-02 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049909#comment-17049909 ] Sophie Blee-Goldman commented on KAFKA-9637: Would be nice to also solve this as a side

[jira] [Commented] (KAFKA-9061) StreamStreamJoinIntegrationTest flaky test failures

2020-03-02 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17049903#comment-17049903 ] Sophie Blee-Goldman commented on KAFKA-9061: Not sure it we can conclude it's been fixed

[jira] [Created] (KAFKA-9467) Multiple wallclock punctuators may be scheduled after a rebalance

2020-01-22 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9467: -- Summary: Multiple wallclock punctuators may be scheduled after a rebalance Key: KAFKA-9467 URL: https://issues.apache.org/jira/browse/KAFKA-9467 Project:

[jira] [Commented] (KAFKA-9467) Multiple wallclock punctuators may be scheduled after a rebalance

2020-01-22 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17021696#comment-17021696 ] Sophie Blee-Goldman commented on KAFKA-9467: Obviously option 3 is a lot more work and may

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-02-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17030057#comment-17030057 ] Sophie Blee-Goldman commented on KAFKA-9455: [~high.lee] I'm pretty certain Guozhang isn't

[jira] [Assigned] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-02-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9455: -- Assignee: highluck > Consider using TreeMap for in-memory stores of Streams >

[jira] [Resolved] (KAFKA-5868) Kafka Consumer Rebalancing takes too long

2020-02-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-5868. Fix Version/s: 2.5.0 Resolution: Fixed > Kafka Consumer Rebalancing takes

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

2020-02-04 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9501: --- Description: The purpose of StandbyTasks in Kafka Streams is fast failover. However,

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-02-03 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029231#comment-17029231 ] Sophie Blee-Goldman commented on KAFKA-9455: This ticket just involves an implementation

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

2020-02-06 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9521: -- Summary: Flaky Test DeleteConsumerGroupsTest#testDeleteCmdEmptyGroup Key: KAFKA-9521 URL: https://issues.apache.org/jira/browse/KAFKA-9521 Project: Kafka

[jira] [Created] (KAFKA-9525) Allow explicit rebalance triggering on the Consumer

2020-02-07 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9525: -- Summary: Allow explicit rebalance triggering on the Consumer Key: KAFKA-9525 URL: https://issues.apache.org/jira/browse/KAFKA-9525 Project: Kafka

[jira] [Commented] (KAFKA-9525) Allow explicit rebalance triggering on the Consumer

2020-02-07 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032763#comment-17032763 ] Sophie Blee-Goldman commented on KAFKA-9525: Well, the point is we want to be able to trigger

[jira] [Assigned] (KAFKA-9525) Allow explicit rebalance triggering on the Consumer

2020-02-07 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-9525: -- Assignee: Sophie Blee-Goldman > Allow explicit rebalance triggering on the

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

2020-02-18 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039352#comment-17039352 ] Sophie Blee-Goldman commented on KAFKA-8858: [~mjsax] I'm not sure – they're both timeouts

[jira] [Created] (KAFKA-9585) Flaky Test: LagFetchIntegrationTest#shouldFetchLagsDuringRebalancingWithOptimization

2020-02-20 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9585: -- Summary: Flaky Test: LagFetchIntegrationTest#shouldFetchLagsDuringRebalancingWithOptimization Key: KAFKA-9585 URL: https://issues.apache.org/jira/browse/KAFKA-9585

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

2020-02-11 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034746#comment-17034746 ] Sophie Blee-Goldman commented on KAFKA-8037: [~pkleindl] [~vvcephei] [~mjsax] [~guozhang] I

[jira] [Commented] (KAFKA-9526) Augment topology description with serdes

2020-02-14 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17037338#comment-17037338 ] Sophie Blee-Goldman commented on KAFKA-9526: When we do this and parse the topology's serdes

[jira] [Created] (KAFKA-9559) Change the default "default serde" from ByteArraySerde to null

2020-02-14 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9559: -- Summary: Change the default "default serde" from ByteArraySerde to null Key: KAFKA-9559 URL: https://issues.apache.org/jira/browse/KAFKA-9559 Project:

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

2020-02-21 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042181#comment-17042181 ] Sophie Blee-Goldman commented on KAFKA-8037: That's a good thought actually – I'm not sure

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

2020-02-21 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042347#comment-17042347 ] Sophie Blee-Goldman commented on KAFKA-8037: Right, duh, we definitely wouldn't want the

[jira] [Updated] (KAFKA-9540) Application getting "Could not find the standby task 0_4 while closing it" error

2020-02-11 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9540: --- Fix Version/s: 2.4.1 > Application getting "Could not find the standby task 0_4

[jira] [Updated] (KAFKA-9540) Application getting "Could not find the standby task 0_4 while closing it" error

2020-02-11 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9540: --- Affects Version/s: 2.5.0 2.4.0 > Application getting "Could

[jira] [Commented] (KAFKA-9540) Application getting "Could not find the standby task 0_4 while closing it" error

2020-02-11 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17034911#comment-17034911 ] Sophie Blee-Goldman commented on KAFKA-9540: Hey [~badai], thanks for the ticket. Your

[jira] [Resolved] (KAFKA-9540) Application getting "Could not find the standby task 0_4 while closing it" error

2020-02-18 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9540. Fix Version/s: 2.6.0 Resolution: Fixed > Application getting "Could not

[jira] [Commented] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

2020-01-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016366#comment-17016366 ] Sophie Blee-Goldman commented on KAFKA-3596: I see, maybe I misunderstood the original ticket

[jira] [Resolved] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

2020-01-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-3596. Resolution: Not A Problem > Kafka Streams: Window expiration needs to consider

[jira] [Commented] (KAFKA-7591) Changelog retention period doesn't synchronise with window-store size

2020-01-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016294#comment-17016294 ] Sophie Blee-Goldman commented on KAFKA-7591: Right, that is why I say if we can't distinguish

[jira] [Commented] (KAFKA-3596) Kafka Streams: Window expiration needs to consider more than event time

2020-01-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016296#comment-17016296 ] Sophie Blee-Goldman commented on KAFKA-3596: [~vvcephei] Can we close this? I think I agree

[jira] [Assigned] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

2020-01-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-6629: -- Assignee: (was: Manasvi Gupta) > SegmentedCacheFunctionTest does not

[jira] [Commented] (KAFKA-6629) SegmentedCacheFunctionTest does not cover session window serdes

2020-01-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016306#comment-17016306 ] Sophie Blee-Goldman commented on KAFKA-6629: Unassigned since there has been no activity for

[jira] [Comment Edited] (KAFKA-9323) Refactor Streams' upgrade system tests

2020-01-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016420#comment-17016420 ] Sophie Blee-Goldman edited comment on KAFKA-9323 at 1/16/20 12:58 AM:

[jira] [Commented] (KAFKA-9323) Refactor Streams' upgrade system tests

2020-01-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016438#comment-17016438 ] Sophie Blee-Goldman commented on KAFKA-9323: I can help you figure out the upgrade matrix

[jira] [Commented] (KAFKA-7591) Changelog retention period doesn't synchronise with window-store size

2020-01-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016372#comment-17016372 ] Sophie Blee-Goldman commented on KAFKA-7591: That's fair, I suppose if it _was_ the window

[jira] [Commented] (KAFKA-9323) Refactor Streams' upgrade system tests

2020-01-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17016420#comment-17016420 ] Sophie Blee-Goldman commented on KAFKA-9323: Hey [~nizhikov], thanks for picking this up! The

[jira] [Updated] (KAFKA-9323) Refactor Streams' upgrade system tests

2020-01-15 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9323: --- Description: With the introduction of version probing in 2.0 and cooperative

[jira] [Created] (KAFKA-9450) Decouple inner state flushing from committing with EOS

2020-01-17 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9450: -- Summary: Decouple inner state flushing from committing with EOS Key: KAFKA-9450 URL: https://issues.apache.org/jira/browse/KAFKA-9450 Project: Kafka

[jira] [Commented] (KAFKA-7591) Changelog retention period doesn't synchronise with window-store size

2020-01-14 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015408#comment-17015408 ] Sophie Blee-Goldman commented on KAFKA-7591: Shouldn't you need to reset the app if the

[jira] [Resolved] (KAFKA-9356) Potential data loss in InMemoryWindowStore and InMemorySessionStore

2020-01-16 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-9356. Resolution: Not A Problem > Potential data loss in InMemoryWindowStore and

[jira] [Commented] (KAFKA-9356) Potential data loss in InMemoryWindowStore and InMemorySessionStore

2020-01-16 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17017748#comment-17017748 ] Sophie Blee-Goldman commented on KAFKA-9356: As [~bchen225242] said, Streams is single writer

[jira] [Updated] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-01-20 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9455: --- Summary: Consider using TreeMap for in-memory stores of Streams (was: Consider

[jira] [Updated] (KAFKA-9455) Consider using TreeMap for In-memory stores of Streams

2020-01-20 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9455: --- Labels: newbie++ (was: ) > Consider using TreeMap for In-memory stores of Streams >

[jira] [Commented] (KAFKA-9455) Consider using TreeMap for in-memory stores of Streams

2020-01-20 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17019772#comment-17019772 ] Sophie Blee-Goldman commented on KAFKA-9455: [~guozhang] I agree with your added thoughts; it

[jira] [Commented] (KAFKA-8037) KTable restore may load bad data

2020-01-02 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007062#comment-17007062 ] Sophie Blee-Goldman commented on KAFKA-8037: > Or should we just transit to normal processing

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

2020-01-02 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007124#comment-17007124 ] Sophie Blee-Goldman commented on KAFKA-7994: The gist of this ticket is "Partition-time, the

[jira] [Commented] (KAFKA-9210) kafka stream loss data

2020-01-03 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17007756#comment-17007756 ] Sophie Blee-Goldman commented on KAFKA-9210: Great! I think we can close this ticket as a

[jira] [Commented] (KAFKA-6614) kafka-streams to configure internal topics message.timestamp.type=CreateTime

2019-12-30 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005891#comment-17005891 ] Sophie Blee-Goldman commented on KAFKA-6614: Hi [~meghanagupta], are you still interested in

[jira] [Created] (KAFKA-9349) Investigate new member timeout for dynamic v4 JoinGroup

2019-12-30 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9349: -- Summary: Investigate new member timeout for dynamic v4 JoinGroup Key: KAFKA-9349 URL: https://issues.apache.org/jira/browse/KAFKA-9349 Project: Kafka

[jira] [Commented] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1

2019-12-30 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005864#comment-17005864 ] Sophie Blee-Goldman commented on KAFKA-8574: Given the fix [~guozhang] mentioned above, this

[jira] [Commented] (KAFKA-7293) Merge followed by groupByKey/join might violate co-partioning

2019-12-30 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005905#comment-17005905 ] Sophie Blee-Goldman commented on KAFKA-7293: [~dongjin] are you still working on this? >

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

2019-12-30 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reopened KAFKA-7994: Assignee: (was: Richard Yu) I'm not sure we should close this yet, it seems

[jira] [Commented] (KAFKA-7041) Using RocksDB bulk loading for StandbyTasks

2019-12-30 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17005808#comment-17005808 ] Sophie Blee-Goldman commented on KAFKA-7041: This is definitely a good idea, but we should

[jira] [Created] (KAFKA-9368) Preserve stream-time across rebalances/restarts

2020-01-06 Thread Sophie Blee-Goldman (Jira)
Sophie Blee-Goldman created KAFKA-9368: -- Summary: Preserve stream-time across rebalances/restarts Key: KAFKA-9368 URL: https://issues.apache.org/jira/browse/KAFKA-9368 Project: Kafka

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

2020-01-06 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-7994: --- Description: We compute a per-partition partition-time as the maximum timestamp over

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

2020-01-06 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17009128#comment-17009128 ] Sophie Blee-Goldman commented on KAFKA-7994: Since we fixed part of this issue but not the

[jira] [Updated] (KAFKA-7994) Improve Partition-Time for rebalances and restarts

2020-01-06 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-7994: --- Summary: Improve Partition-Time for rebalances and restarts (was: Improve

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

2020-01-07 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010255#comment-17010255 ] Sophie Blee-Goldman commented on KAFKA-7317: Disabling auto-topic creation is possible for

[jira] [Commented] (KAFKA-8821) Avoid pattern subscription to allow for stricter ACL settings

2020-01-07 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17010252#comment-17010252 ] Sophie Blee-Goldman commented on KAFKA-8821: Disabling auto-topic creation is possible for

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

2020-03-12 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9225: --- Fix Version/s: (was: 3.0.0) > kafka fail to run on linux-aarch64 >

[jira] [Updated] (KAFKA-9588) Add rocksdb event listeners in KS

2020-03-12 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9588: --- Fix Version/s: 3.0.0 > Add rocksdb event listeners in KS >

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