[jira] [Created] (KAFKA-3835) Streams is creating two ProducerRecords for each send via RecordCollector

Damian Guy created KAFKA-3835: - Summary: Streams is creating two ProducerRecords for each send via RecordCollector Key: KAFKA-3835 URL: https://issues.apache.org/jira/browse/KAFKA-3835 Project: Kafka

[jira] [Updated] (KAFKA-3835) Streams is creating two ProducerRecords for each send via RecordCollector

[ https://issues.apache.org/jira/browse/KAFKA-3835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3835: -- Description: The RecordCollector.send(..) method below, currently receives a ProducerRecord from its

[jira] [Updated] (KAFKA-3835) Streams is creating two ProducerRecords for each send via RecordCollector

[ https://issues.apache.org/jira/browse/KAFKA-3835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3835: -- Description: The RecordCollector.send(..) method below, currently receives a ProducerRecord from its

[jira] [Updated] (KAFKA-3835) Streams is creating two ProducerRecords for each send via RecordCollector

[ https://issues.apache.org/jira/browse/KAFKA-3835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3835: -- Description: The RecordCollector.send(..) method below, currently receives a ProducerRecord from its

[jira] [Commented] (KAFKA-3561) Auto create through topic for KStream aggregation and join

[ https://issues.apache.org/jira/browse/KAFKA-3561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15303877#comment-15303877 ] Damian Guy commented on KAFKA-3561: --- Guozhang - i'd like to do this if it is ok with you. I'm going to

[jira] [Assigned] (KAFKA-3561) Auto create through topic for KStream aggregation and join

[ https://issues.apache.org/jira/browse/KAFKA-3561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-3561: - Assignee: Damian Guy > Auto create through topic for KStream aggregation and join >

[jira] [Resolved] (KAFKA-3874) Transient test failure: org.apache.kafka.streams.integration.JoinIntegrationTest.shouldCountClicksPerRegion

[ https://issues.apache.org/jira/browse/KAFKA-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-3874. --- Resolution: Fixed Fix Version/s: 0.10.1.0 Should be fixed by:

[jira] [Commented] (KAFKA-3874) Transient test failure: org.apache.kafka.streams.integration.JoinIntegrationTest.shouldCountClicksPerRegion

[ https://issues.apache.org/jira/browse/KAFKA-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15341627#comment-15341627 ] Damian Guy commented on KAFKA-3874: --- This should be fixed with the commit yesterday. I'll keep an eye on

[jira] [Resolved] (KAFKA-3576) Unify KStream and KTable API

[ https://issues.apache.org/jira/browse/KAFKA-3576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-3576. --- Resolution: Resolved Resolved by https://issues.apache.org/jira/browse/KAFKA-3561 > Unify KStream

[jira] [Issue Comment Deleted] (KAFKA-3873) Gradle Test Executor non-zero exit code when running streams tests

[ https://issues.apache.org/jira/browse/KAFKA-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3873: -- Comment: was deleted (was: This should be fixed - it was due to setting {code}

[jira] [Commented] (KAFKA-3873) Gradle Test Executor non-zero exit code when running streams tests

[ https://issues.apache.org/jira/browse/KAFKA-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15339455#comment-15339455 ] Damian Guy commented on KAFKA-3873: --- This should be fixed - it was due to setting {code}

[jira] [Updated] (KAFKA-3896) Unstable test KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations

[ https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3896: -- Assignee: Damian Guy > Unstable test >

[jira] [Created] (KAFKA-3898) KStream.leftJoin(...) is missing a Serde for thisVal. This can cause failures after mapValues etc

Damian Guy created KAFKA-3898: - Summary: KStream.leftJoin(...) is missing a Serde for thisVal. This can cause failures after mapValues etc Key: KAFKA-3898 URL: https://issues.apache.org/jira/browse/KAFKA-3898

[jira] [Commented] (KAFKA-3898) KStream.leftJoin(...) is missing a Serde for thisVal. This can cause failures after mapValues etc

[ https://issues.apache.org/jira/browse/KAFKA-3898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347901#comment-15347901 ] Damian Guy commented on KAFKA-3898: --- If the stream has been mapped or flatMapped it needs the Serdes

[jira] [Commented] (KAFKA-3898) KStream.leftJoin(...) is missing a Serde for thisVal. This can cause failures after mapValues etc

[ https://issues.apache.org/jira/browse/KAFKA-3898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347928#comment-15347928 ] Damian Guy commented on KAFKA-3898: --- Turns out this is not an issue on 0.10.0 - my mistake. It was an

[jira] [Resolved] (KAFKA-3898) KStream.leftJoin(...) is missing a Serde for thisVal. This can cause failures after mapValues etc

[ https://issues.apache.org/jira/browse/KAFKA-3898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-3898. --- Resolution: Not A Problem > KStream.leftJoin(...) is missing a Serde for thisVal. This can cause

[jira] [Updated] (KAFKA-3912) Query local state stores

[ https://issues.apache.org/jira/browse/KAFKA-3912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3912: -- Description: Implement read-only interface and QueryableStoreType for key-value state store Implement

[jira] [Created] (KAFKA-3912) Query local state stores

Damian Guy created KAFKA-3912: - Summary: Query local state stores Key: KAFKA-3912 URL: https://issues.apache.org/jira/browse/KAFKA-3912 Project: Kafka Issue Type: Sub-task Components:

[jira] [Created] (KAFKA-3914) Global discovery of state stores

Damian Guy created KAFKA-3914: - Summary: Global discovery of state stores Key: KAFKA-3914 URL: https://issues.apache.org/jira/browse/KAFKA-3914 Project: Kafka Issue Type: Sub-task

[jira] [Work started] (KAFKA-3912) Query local state stores

[ https://issues.apache.org/jira/browse/KAFKA-3912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3912 started by Damian Guy. - > Query local state stores > > > Key:

[jira] [Created] (KAFKA-3629) KStreamImpl.to(...) throws NPE when the value SerDe is null

Damian Guy created KAFKA-3629: - Summary: KStreamImpl.to(...) throws NPE when the value SerDe is null Key: KAFKA-3629 URL: https://issues.apache.org/jira/browse/KAFKA-3629 Project: Kafka Issue

[jira] [Commented] (KAFKA-3589) KTable.count(final KeyValueMapper<K, V, K1> selector, String name) throw NPE

[ https://issues.apache.org/jira/browse/KAFKA-3589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15251533#comment-15251533 ] Damian Guy commented on KAFKA-3589: --- LGTM > KTable.count(final KeyValueMapper selector,

[jira] [Work started] (KAFKA-3929) Add prefix for underlying clients configs in StreamConfig

[ https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3929 started by Damian Guy. - > Add prefix for underlying clients configs in StreamConfig >

[jira] [Updated] (KAFKA-3929) Add prefix for underlying clients configs in StreamConfig

[ https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3929: -- Status: Patch Available (was: In Progress) > Add prefix for underlying clients configs in StreamConfig

[jira] [Assigned] (KAFKA-3929) Add prefix for underlying clients configs in StreamConfig

[ https://issues.apache.org/jira/browse/KAFKA-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-3929: - Assignee: Damian Guy (was: Ishita Mandhan) > Add prefix for underlying clients configs in

[jira] [Commented] (KAFKA-3777) Extract the existing LRU cache out of RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417518#comment-15417518 ] Damian Guy commented on KAFKA-3777: --- We need to support concurrent access (Queryable State), so it is

[jira] [Assigned] (KAFKA-3595) Add capability to specify replication compact option for stream store

[ https://issues.apache.org/jira/browse/KAFKA-3595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-3595: - Assignee: Damian Guy > Add capability to specify replication compact option for stream store >

[jira] [Assigned] (KAFKA-3452) Support session windows besides time interval windows

[ https://issues.apache.org/jira/browse/KAFKA-3452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-3452: - Assignee: Damian Guy > Support session windows besides time interval windows >

[jira] [Resolved] (KAFKA-3909) Queryable state for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-3909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-3909. --- Resolution: Fixed > Queryable state for Kafka Streams > - > >

[jira] [Assigned] (KAFKA-3812) State store locking is incorrect

[ https://issues.apache.org/jira/browse/KAFKA-3812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-3812: - Assignee: Damian Guy (was: Eno Thereska) > State store locking is incorrect >

[jira] [Work started] (KAFKA-3855) Guard race conditions in TopologyBuilder

[ https://issues.apache.org/jira/browse/KAFKA-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3855 started by Damian Guy. - > Guard race conditions in TopologyBuilder >

[jira] [Assigned] (KAFKA-3855) Guard race conditions in TopologyBuilder

[ https://issues.apache.org/jira/browse/KAFKA-3855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-3855: - Assignee: Damian Guy > Guard race conditions in TopologyBuilder >

[jira] [Updated] (KAFKA-3740) Enable configuration of RocksDBStores

[ https://issues.apache.org/jira/browse/KAFKA-3740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3740: -- Summary: Enable configuration of RocksDBStores (was: Add configs for RocksDBStores) > Enable

[jira] [Resolved] (KAFKA-3873) Gradle Test Executor non-zero exit code when running streams tests

[ https://issues.apache.org/jira/browse/KAFKA-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-3873. --- Resolution: Duplicate Fix Version/s: 0.10.1.0 Fixed by KAFKA-3896 > Gradle Test Executor

[jira] [Assigned] (KAFKA-3873) Gradle Test Executor non-zero exit code when running streams tests

[ https://issues.apache.org/jira/browse/KAFKA-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-3873: - Assignee: Damian Guy (was: Guozhang Wang) > Gradle Test Executor non-zero exit code when

[jira] [Resolved] (KAFKA-3884) KGroupedStreamIntegrationTest.shouldAggregate seems to be hanging

[ https://issues.apache.org/jira/browse/KAFKA-3884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-3884. --- Resolution: Fixed Fixed by KAFKA-3842 > KGroupedStreamIntegrationTest.shouldAggregate seems to be

[jira] [Created] (KAFKA-3942) Change IntegrationTestUtils.purgeLocalStreamsState to use java.io.tmpdir

Damian Guy created KAFKA-3942: - Summary: Change IntegrationTestUtils.purgeLocalStreamsState to use java.io.tmpdir Key: KAFKA-3942 URL: https://issues.apache.org/jira/browse/KAFKA-3942 Project: Kafka

[jira] [Updated] (KAFKA-3936) Validate user parameters as early as possible

[ https://issues.apache.org/jira/browse/KAFKA-3936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-3936: -- Status: Patch Available (was: Open) > Validate user parameters as early as possible >

[jira] [Work started] (KAFKA-3914) Global discovery of state stores

[ https://issues.apache.org/jira/browse/KAFKA-3914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3914 started by Damian Guy. - > Global discovery of state stores > > >

[jira] (KAFKA-4317) RocksDB checkpoint files lost on kill -9

[ https://issues.apache.org/jira/browse/KAFKA-4317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4317: -- Status: Patch Available (was: Open) > RocksDB checkpoint files lost on kill -9 >

[jira] [Updated] (KAFKA-4724) Clean up of state directories has a race condition and can possibly remove stores that are still used

[ https://issues.apache.org/jira/browse/KAFKA-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4724: -- Summary: Clean up of state directories has a race condition and can possibly remove stores that are

[jira] [Updated] (KAFKA-4724) Clean up of state directories can possibly remove stores that are about to be used by another thread

[ https://issues.apache.org/jira/browse/KAFKA-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4724: -- Summary: Clean up of state directories can possibly remove stores that are about to be used by another

[jira] [Created] (KAFKA-4724) Clean up of state directories has a race condition and can possibly remove stores that are sill used

Damian Guy created KAFKA-4724: - Summary: Clean up of state directories has a race condition and can possibly remove stores that are sill used Key: KAFKA-4724 URL: https://issues.apache.org/jira/browse/KAFKA-4724

[jira] [Assigned] (KAFKA-4724) Clean up of state directories has a race condition and can possibly remove stores that are still used

[ https://issues.apache.org/jira/browse/KAFKA-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4724: - Assignee: Damian Guy > Clean up of state directories has a race condition and can possibly

[jira] [Resolved] (KAFKA-4182) Move the change logger out of RocksDB stores

[ https://issues.apache.org/jira/browse/KAFKA-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-4182. --- Resolution: Fixed Fix Version/s: 0.10.2.0 Fixed by: https://github.com/apache/kafka/pull/2360

[jira] [Updated] (KAFKA-4646) Improve test coverage AbstractProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4646: -- Status: Patch Available (was: Reopened) > Improve test coverage AbstractProcessorContext >

[jira] [Work started] (KAFKA-4642) Improve test coverage of ProcessorStateManager

[ https://issues.apache.org/jira/browse/KAFKA-4642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4642 started by Damian Guy. - > Improve test coverage of ProcessorStateManager >

[jira] [Updated] (KAFKA-4645) Improve test coverage of ProcessorTopology

[ https://issues.apache.org/jira/browse/KAFKA-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4645: -- Status: Patch Available (was: Open) > Improve test coverage of ProcessorTopology >

[jira] [Assigned] (KAFKA-4644) Improve test coverage of StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4644: - Assignee: Damian Guy > Improve test coverage of StreamsPartitionAssignor >

[jira] [Assigned] (KAFKA-4642) Improve test coverage of ProcessorStateManager

[ https://issues.apache.org/jira/browse/KAFKA-4642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4642: - Assignee: Damian Guy > Improve test coverage of ProcessorStateManager >

[jira] [Assigned] (KAFKA-4645) Improve test coverage of ProcessorTopology

[ https://issues.apache.org/jira/browse/KAFKA-4645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4645: - Assignee: Damian Guy > Improve test coverage of ProcessorTopology >

[jira] [Updated] (KAFKA-4642) Improve test coverage of ProcessorStateManager

[ https://issues.apache.org/jira/browse/KAFKA-4642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4642: -- Status: Patch Available (was: In Progress) > Improve test coverage of ProcessorStateManager >

[jira] [Assigned] (KAFKA-4646) Improve test coverage AbstractProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4646: - Assignee: Damian Guy > Improve test coverage AbstractProcessorContext >

[jira] [Assigned] (KAFKA-4648) Improve test coverage StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-4648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4648: - Assignee: Damian Guy > Improve test coverage StreamTask > > >

[jira] [Updated] (KAFKA-4644) Improve test coverage of StreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-4644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4644: -- Status: Patch Available (was: Open) > Improve test coverage of StreamsPartitionAssignor >

[jira] [Updated] (KAFKA-4648) Improve test coverage StreamTask

[ https://issues.apache.org/jira/browse/KAFKA-4648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4648: -- Status: Patch Available (was: Open) > Improve test coverage StreamTask >

[jira] [Assigned] (KAFKA-4647) Improve test coverage of GlobalStreamThread

[ https://issues.apache.org/jira/browse/KAFKA-4647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4647: - Assignee: Damian Guy > Improve test coverage of GlobalStreamThread >

[jira] [Assigned] (KAFKA-4649) Improve test coverage GlobalStateManagerImpl

[ https://issues.apache.org/jira/browse/KAFKA-4649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4649: - Assignee: Damian Guy > Improve test coverage GlobalStateManagerImpl >

[jira] [Updated] (KAFKA-4647) Improve test coverage of GlobalStreamThread

[ https://issues.apache.org/jira/browse/KAFKA-4647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4647: -- Status: Patch Available (was: Open) > Improve test coverage of GlobalStreamThread >

[jira] [Updated] (KAFKA-4649) Improve test coverage GlobalStateManagerImpl

[ https://issues.apache.org/jira/browse/KAFKA-4649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4649: -- Status: Patch Available (was: Open) > Improve test coverage GlobalStateManagerImpl >

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

Damian Guy created KAFKA-4696: - Summary: Streams standby task assignment should be state-store aware Key: KAFKA-4696 URL: https://issues.apache.org/jira/browse/KAFKA-4696 Project: Kafka Issue

[jira] [Created] (KAFKA-4677) Make StreamPartitionAssigner more sticky when assigning to threads

Damian Guy created KAFKA-4677: - Summary: Make StreamPartitionAssigner more sticky when assigning to threads Key: KAFKA-4677 URL: https://issues.apache.org/jira/browse/KAFKA-4677 Project: Kafka

[jira] [Updated] (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 ] Damian Guy updated KAFKA-4696: -- Description: Task Assignment is currently not aware of which tasks have State Stores. This can result

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

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reopened KAFKA-4222: --- re-opening as there was one more case of this recently. However the build has been cleaned up. Just

[jira] [Assigned] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

[ https://issues.apache.org/jira/browse/KAFKA-4650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4650: - Assignee: Damian Guy > Improve test coverage org.apache.kafka.streams.kstream.internals >

[jira] [Assigned] (KAFKA-4317) RocksDB checkpoint files lost on kill -9

[ https://issues.apache.org/jira/browse/KAFKA-4317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4317: - Assignee: Damian Guy > RocksDB checkpoint files lost on kill -9 >

[jira] [Commented] (KAFKA-4791) Kafka Streams - unable to add state stores when using wildcard topics on the source

[ https://issues.apache.org/jira/browse/KAFKA-4791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15881280#comment-15881280 ] Damian Guy commented on KAFKA-4791: --- [~mjsax] this is a bug. Bart is calling {{addStateStore}} which is,

[jira] [Work started] (KAFKA-4494) Significant startup delays in KStreams app

[ https://issues.apache.org/jira/browse/KAFKA-4494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4494 started by Damian Guy. - > Significant startup delays in KStreams app >

[jira] [Assigned] (KAFKA-4494) Significant startup delays in KStreams app

[ https://issues.apache.org/jira/browse/KAFKA-4494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4494: - Assignee: Damian Guy > Significant startup delays in KStreams app >

[jira] [Work started] (KAFKA-4484) Set more conservative default values on RocksDB for memory usage

[ https://issues.apache.org/jira/browse/KAFKA-4484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4484 started by Damian Guy. - > Set more conservative default values on RocksDB for memory usage >

[jira] [Assigned] (KAFKA-4484) Set more conservative default values on RocksDB for memory usage

[ https://issues.apache.org/jira/browse/KAFKA-4484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-4484: - Assignee: Damian Guy > Set more conservative default values on RocksDB for memory usage >

[jira] [Updated] (KAFKA-4484) Set more conservative default values on RocksDB for memory usage

[ https://issues.apache.org/jira/browse/KAFKA-4484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4484: -- Status: Patch Available (was: In Progress) > Set more conservative default values on RocksDB for

[jira] [Created] (KAFKA-4752) Streams Simple Benchmark MB/sec calculation is not correct for Join operations

Damian Guy created KAFKA-4752: - Summary: Streams Simple Benchmark MB/sec calculation is not correct for Join operations Key: KAFKA-4752 URL: https://issues.apache.org/jira/browse/KAFKA-4752 Project:

[jira] [Work started] (KAFKA-4588) QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable is occasionally failing on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-4588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4588 started by Damian Guy. - > QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable >

[jira] [Updated] (KAFKA-4588) QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable is occasionally failing on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-4588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4588: -- Status: Patch Available (was: In Progress) >

[jira] [Created] (KAFKA-4641) Improve test coverage of StreamsThread

Damian Guy created KAFKA-4641: - Summary: Improve test coverage of StreamsThread Key: KAFKA-4641 URL: https://issues.apache.org/jira/browse/KAFKA-4641 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4643) Improve test coverage of StreamsKafkaClient

Damian Guy created KAFKA-4643: - Summary: Improve test coverage of StreamsKafkaClient Key: KAFKA-4643 URL: https://issues.apache.org/jira/browse/KAFKA-4643 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4646) Improve Streams unit test coverage

Damian Guy created KAFKA-4646: - Summary: Improve Streams unit test coverage Key: KAFKA-4646 URL: https://issues.apache.org/jira/browse/KAFKA-4646 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4645) Improve test coverage of ProcessorTopology

Damian Guy created KAFKA-4645: - Summary: Improve test coverage of ProcessorTopology Key: KAFKA-4645 URL: https://issues.apache.org/jira/browse/KAFKA-4645 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4654) Improve test coverage MemoryLRUCache

Damian Guy created KAFKA-4654: - Summary: Improve test coverage MemoryLRUCache Key: KAFKA-4654 URL: https://issues.apache.org/jira/browse/KAFKA-4654 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4658) Improve test coverage InMemoryKeyValueLoggedStore

Damian Guy created KAFKA-4658: - Summary: Improve test coverage InMemoryKeyValueLoggedStore Key: KAFKA-4658 URL: https://issues.apache.org/jira/browse/KAFKA-4658 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-4660) Improve test coverage KafkaStreams

Damian Guy created KAFKA-4660: - Summary: Improve test coverage KafkaStreams Key: KAFKA-4660 URL: https://issues.apache.org/jira/browse/KAFKA-4660 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4642) Improve test coverage of ProcessorStateManager

Damian Guy created KAFKA-4642: - Summary: Improve test coverage of ProcessorStateManager Key: KAFKA-4642 URL: https://issues.apache.org/jira/browse/KAFKA-4642 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-4646) Improve test coverage AbstractProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4646: -- Summary: Improve test coverage AbstractProcessorContext (was: Improve Streams unit test coverage) >

[jira] [Reopened] (KAFKA-4646) Improve test coverage AbstractProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reopened KAFKA-4646: --- Exception paths in {{register}}, {{topic}}, {{partition}}, {{offset}}, {{timestamp}} > Improve test

[jira] [Updated] (KAFKA-4647) Improve test coverage of GlobalStreamThread

[ https://issues.apache.org/jira/browse/KAFKA-4647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4647: -- Priority: Minor (was: Major) > Improve test coverage of GlobalStreamThread >

[jira] [Created] (KAFKA-4647) Improve test coverage of GlobalStreamThread

Damian Guy created KAFKA-4647: - Summary: Improve test coverage of GlobalStreamThread Key: KAFKA-4647 URL: https://issues.apache.org/jira/browse/KAFKA-4647 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4648) Improve test coverage StreamTask

Damian Guy created KAFKA-4648: - Summary: Improve test coverage StreamTask Key: KAFKA-4648 URL: https://issues.apache.org/jira/browse/KAFKA-4648 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4650) Improve test coverage org.apache.kafka.streams.kstream.internals

Damian Guy created KAFKA-4650: - Summary: Improve test coverage org.apache.kafka.streams.kstream.internals Key: KAFKA-4650 URL: https://issues.apache.org/jira/browse/KAFKA-4650 Project: Kafka

[jira] [Created] (KAFKA-4652) Improve test coverage KStreamBuilder

Damian Guy created KAFKA-4652: - Summary: Improve test coverage KStreamBuilder Key: KAFKA-4652 URL: https://issues.apache.org/jira/browse/KAFKA-4652 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4661) Improve test coverage UsePreviousTimeOnInvalidTimestamp

Damian Guy created KAFKA-4661: - Summary: Improve test coverage UsePreviousTimeOnInvalidTimestamp Key: KAFKA-4661 URL: https://issues.apache.org/jira/browse/KAFKA-4661 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-4662) Improve test coverage TopologyBuilder

[ https://issues.apache.org/jira/browse/KAFKA-4662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4662: -- Description: overloaded {{addSource}} methods with {{AutoOffsetReset}} param not tested. Also some

[jira] [Resolved] (KAFKA-4646) Improve Streams unit test coverage

[ https://issues.apache.org/jira/browse/KAFKA-4646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-4646. --- Resolution: Duplicate > Improve Streams unit test coverage > -- > >

[jira] [Created] (KAFKA-4649) Improve test coverage GlobalStateManagerImpl

Damian Guy created KAFKA-4649: - Summary: Improve test coverage GlobalStateManagerImpl Key: KAFKA-4649 URL: https://issues.apache.org/jira/browse/KAFKA-4649 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4651) Improve test coverage of Stores

Damian Guy created KAFKA-4651: - Summary: Improve test coverage of Stores Key: KAFKA-4651 URL: https://issues.apache.org/jira/browse/KAFKA-4651 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4656) Improve test coverage of CompositeReadOnlyKeyValueStore

Damian Guy created KAFKA-4656: - Summary: Improve test coverage of CompositeReadOnlyKeyValueStore Key: KAFKA-4656 URL: https://issues.apache.org/jira/browse/KAFKA-4656 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-4655) Improve test coverage of CompositeReadOnlySessionStore

Damian Guy created KAFKA-4655: - Summary: Improve test coverage of CompositeReadOnlySessionStore Key: KAFKA-4655 URL: https://issues.apache.org/jira/browse/KAFKA-4655 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-4659) Improve test coverage of CachingKeyValueStore

Damian Guy created KAFKA-4659: - Summary: Improve test coverage of CachingKeyValueStore Key: KAFKA-4659 URL: https://issues.apache.org/jira/browse/KAFKA-4659 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-4640) Improve Streams unit test coverage

Damian Guy created KAFKA-4640: - Summary: Improve Streams unit test coverage Key: KAFKA-4640 URL: https://issues.apache.org/jira/browse/KAFKA-4640 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-4644) Improve test coverage of StreamsPartitionAssignor

Damian Guy created KAFKA-4644: - Summary: Improve test coverage of StreamsPartitionAssignor Key: KAFKA-4644 URL: https://issues.apache.org/jira/browse/KAFKA-4644 Project: Kafka Issue Type:

  1   2   3   4   >