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

2017-01-19 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15831285#comment-15831285 ] Guozhang Wang commented on KAFKA-3896: -- The root cause of this issue is that before

[jira] [Commented] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

2017-01-18 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829268#comment-15829268 ] Guozhang Wang commented on KAFKA-4631: -- I think we do not need a new config for this, hard-coded

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

2017-01-18 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15829117#comment-15829117 ] Guozhang Wang commented on KAFKA-4222: -- [~mjsax] Found this failure again after the previous PR is

[jira] [Updated] (KAFKA-3738) Add load system tests for Streams

2017-01-17 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3738: - Issue Type: Task (was: Bug) > Add load system tests for Streams >

[jira] [Updated] (KAFKA-3738) Add load system tests for Streams

2017-01-17 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3738: - Description: Today in system tests we have mainly two types of tests: 1) correctness tests for

[jira] [Updated] (KAFKA-3738) Add load system tests for Streams

2017-01-17 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3738: - Summary: Add load system tests for Streams (was: Add system test against memory leak in Kafka

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

2017-01-17 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4588: - Resolution: Fixed Fix Version/s: 0.10.3.0 Status: Resolved (was: Patch

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

2017-01-17 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15826752#comment-15826752 ] Guozhang Wang commented on KAFKA-3896: -- Another instance:

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

2017-01-17 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3896: - Assignee: Guozhang Wang (was: Damian Guy) > Unstable test >

[jira] [Updated] (KAFKA-4639) Kafka Streams metrics are undocumented

2017-01-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4639: - Assignee: Eno Thereska > Kafka Streams metrics are undocumented >

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

2017-01-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4182: - Summary: Move the change logger out of RocksDB stores (was: Move the change logger our of

[jira] [Commented] (KAFKA-4421) Update release process so that Scala 2.12 artifacts are published

2017-01-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15824512#comment-15824512 ] Guozhang Wang commented on KAFKA-4421: -- [~ijuma] Ah yes, I did. This needs to be written down as

[jira] [Commented] (KAFKA-4421) Update release process so that Scala 2.12 artifacts are published

2017-01-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15824470#comment-15824470 ] Guozhang Wang commented on KAFKA-4421: -- I added a one liner note on the release process wiki while

[jira] [Resolved] (KAFKA-4604) Gradle Eclipse plugin creates projects for non project subfolders

2017-01-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4604. -- Resolution: Duplicate > Gradle Eclipse plugin creates projects for non project subfolders >

[jira] [Updated] (KAFKA-4619) Dissallow to output records with unknown keys in TransformValues

2017-01-16 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4619: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Work started] (KAFKA-3502) Build is killed during kafka streams tests due to `pure virtual method called` error

2017-01-14 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3502 started by Guozhang Wang. > Build is killed during kafka streams tests due to `pure virtual method >

[jira] [Resolved] (KAFKA-3901) KStreamTransformValues$KStreamTransformValuesProcessor#process() forwards null values

2017-01-14 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3901. -- Resolution: Won't Fix > KStreamTransformValues$KStreamTransformValuesProcessor#process()

[jira] [Updated] (KAFKA-3515) Migrate org.apache.kafka.connect.json.JsonSerializer / Deser to common package

2017-01-14 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3515: - Labels: needs-kip (was: ) > Migrate org.apache.kafka.connect.json.JsonSerializer / Deser to

[jira] [Comment Edited] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

2017-01-14 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822837#comment-15822837 ] Guozhang Wang edited comment on KAFKA-4125 at 1/14/17 3:38 PM: --- Thanks for

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

2017-01-14 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822837#comment-15822837 ] Guozhang Wang commented on KAFKA-4125: -- Thanks for bringing this up [~mjsax]. I do agree that we have

[jira] [Created] (KAFKA-4633) Always use regex pattern subscription to avoid auto create topics

2017-01-13 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-4633: Summary: Always use regex pattern subscription to avoid auto create topics Key: KAFKA-4633 URL: https://issues.apache.org/jira/browse/KAFKA-4633 Project: Kafka

[jira] [Commented] (KAFKA-4614) Long GC pause harming broker performance which is caused by mmap objects created for OffsetIndex

2017-01-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822254#comment-15822254 ] Guozhang Wang commented on KAFKA-4614: -- Thanks for this report and thorough analysis [~kawamuray]!

[jira] [Resolved] (KAFKA-3739) Add no-arg constructor for library provided serdes

2017-01-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3739. -- Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request 2308

[jira] [Commented] (KAFKA-3537) Provide access to low-level Metrics in ProcessorContext

2017-01-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822002#comment-15822002 ] Guozhang Wang commented on KAFKA-3537: -- [~mdcoon1] In the coming 0.10.2.0 release users can get the

[jira] [Resolved] (KAFKA-3537) Provide access to low-level Metrics in ProcessorContext

2017-01-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3537. -- Resolution: Fixed Resolved as part of PR 1446. > Provide access to low-level Metrics in

[jira] [Updated] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1482: - Component/s: unit tests > Transient test failures for >

[jira] [Reopened] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-1482: -- > Transient test failures for >

[jira] [Updated] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1482: - Fix Version/s: (was: 0.8.2.0) 0.10.3.0 > Transient test failures for >

[jira] [Commented] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15820321#comment-15820321 ] Guozhang Wang commented on KAFKA-1482: -- Saw this test failure in another example:

[jira] [Updated] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1482: - Summary: Transient test failures for

[jira] [Updated] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1482: - Description: {code} Stacktrace kafka.common.TopicAlreadyMarkedForDeletionException: topic test

[jira] [Resolved] (KAFKA-2543) facing test failure while building apache-kafka from source

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2543. -- Resolution: Cannot Reproduce > facing test failure while building apache-kafka from source >

[jira] [Commented] (KAFKA-4604) Gradle Eclipse plugin creates projects for non project subfolders

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15820176#comment-15820176 ] Guozhang Wang commented on KAFKA-4604: -- PR link:https://github.com/apache/kafka/pull/2324 > Gradle

[jira] [Updated] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4114: - Resolution: Fixed Fix Version/s: 0.10.2.0 Status: Resolved (was: Patch

[jira] [Commented] (KAFKA-3875) Transient test failure: kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819602#comment-15819602 ] Guozhang Wang commented on KAFKA-3875: -- Another failure with different error message: {code}

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

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4588: - Issue Type: Sub-task (was: Bug) Parent: KAFKA-2054 >

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

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4222: - Issue Type: Sub-task (was: Bug) Parent: KAFKA-2054 > Transient failure in

[jira] [Commented] (KAFKA-3875) Transient test failure: kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819596#comment-15819596 ] Guozhang Wang commented on KAFKA-3875: -- Another failure case of this:

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

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3896: - Issue Type: Sub-task (was: Bug) Parent: KAFKA-2054 > Unstable test >

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

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-3896: -- > Unstable test > KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations >

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

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819555#comment-15819555 ] Guozhang Wang commented on KAFKA-3896: -- {code} java.lang.AssertionError: Condition not met within

[jira] [Resolved] (KAFKA-3715) Higher granularity streams metrics

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3715. -- Resolution: Fixed > Higher granularity streams metrics > --- >

[jira] [Updated] (KAFKA-4060) Remove ZkClient dependency in Kafka Streams

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4060: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-4481) Relax Kafka Streams API type constraints

2017-01-11 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4481: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-4604) Gradle Eclipse plugin creates projects for non project subfolders

2017-01-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4604: - Assignee: Dhwani Katagade > Gradle Eclipse plugin creates projects for non project subfolders >

[jira] [Commented] (KAFKA-4604) Gradle Eclipse plugin creates projects for non project subfolders

2017-01-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816000#comment-15816000 ] Guozhang Wang commented on KAFKA-4604: -- BTW I have just assigned it to you. > Gradle Eclipse plugin

[jira] [Commented] (KAFKA-4604) Gradle Eclipse plugin creates projects for non project subfolders

2017-01-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815872#comment-15815872 ] Guozhang Wang commented on KAFKA-4604: -- Just curious is it only an issue for `ecplise` or it is also

[jira] [Updated] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in incorrect results

2017-01-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4609: - Labels: architecture (was: ) > KTable/KTable join followed by groupBy and aggregate/count can

[jira] [Updated] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in incorrect results

2017-01-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4609: - Component/s: streams > KTable/KTable join followed by groupBy and aggregate/count can result in

[jira] [Updated] (KAFKA-4603) the argument of shell in doc wrong and command parsed error

2017-01-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4603: - Assignee: Xin > the argument of shell in doc wrong and command parsed error >

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

2017-01-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15813181#comment-15813181 ] Guozhang Wang commented on KAFKA-4125: -- [~bbejeck] Could you lead a KIP proposal / discussion on this

[jira] [Resolved] (KAFKA-4551) StreamsSmokeTest.test_streams intermittent failure

2017-01-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4551. -- Resolution: Fixed Fix Version/s: (was: 0.10.1.2) 0.10.2.0 Issue

[jira] [Assigned] (KAFKA-3502) Build is killed during kafka streams tests due to `pure virtual method called` error

2017-01-06 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-3502: Assignee: Guozhang Wang > Build is killed during kafka streams tests due to `pure virtual

[jira] [Updated] (KAFKA-4607) Kafka Streams allows you to provide strings with illegal characters for internal topic names

2017-01-06 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4607: - Assignee: Nikki Thean > Kafka Streams allows you to provide strings with illegal characters for

[jira] [Resolved] (KAFKA-1908) Split brain

2017-01-06 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-1908. -- Resolution: Not A Problem > Split brain > --- > > Key: KAFKA-1908 >

[jira] [Updated] (KAFKA-3452) Support session windows

2017-01-06 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3452: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Commented] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

2017-01-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802904#comment-15802904 ] Guozhang Wang commented on KAFKA-4601: -- [~bbejeck] Note that it may be more complex than it sounds:

[jira] [Created] (KAFKA-4601) Avoid duplicated repartitioning in KStream DSL

2017-01-05 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-4601: Summary: Avoid duplicated repartitioning in KStream DSL Key: KAFKA-4601 URL: https://issues.apache.org/jira/browse/KAFKA-4601 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-4592) Kafka Producer Metrics Invalid Value

2017-01-05 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15802054#comment-15802054 ] Guozhang Wang commented on KAFKA-4592: -- @huxi Could you follow the process described here for

[jira] [Created] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

2017-01-04 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-4593: Summary: Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException Key: KAFKA-4593 URL:

[jira] [Created] (KAFKA-4587) Rethink Unification of Caching with Dedupping

2017-01-03 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-4587: Summary: Rethink Unification of Caching with Dedupping Key: KAFKA-4587 URL: https://issues.apache.org/jira/browse/KAFKA-4587 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-4584) Fail the 'kafka-configs' command if the config to be removed does not exist

2017-01-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4584: - Resolution: Fixed Fix Version/s: 0.10.2.0 Status: Resolved (was: Patch

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

2017-01-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15795576#comment-15795576 ] Guozhang Wang commented on KAFKA-4222: -- Re-opening this issue as we have seen it happen again with a

[jira] [Commented] (KAFKA-4550) current trunk unstable

2017-01-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15795573#comment-15795573 ] Guozhang Wang commented on KAFKA-4550: -- I'm re-opening

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

2017-01-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-4222: -- > Transient failure in QueryableStateIntegrationTest.queryOnRebalance >

[jira] [Updated] (KAFKA-4528) Failure in kafka.producer.ProducerTest.testAsyncSendCanCorrectlyFailWithTimeout

2017-01-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4528: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-2434) remove roundrobin identical topic constraint in consumer coordinator (old API)

2017-01-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2434: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-4561) Ordering of operations in StreamThread.shutdownTasksAndState may void at-least-once guarantees

2017-01-03 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4561: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-4480) kafka-configs will execute the removal of an invalid property and not report an error

2016-12-31 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4480: - Resolution: Fixed Fix Version/s: 0.10.2.0 Status: Resolved (was: Patch

[jira] [Created] (KAFKA-4569) Transient failure in org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable

2016-12-23 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-4569: Summary: Transient failure in org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable Key: KAFKA-4569 URL:

[jira] [Updated] (KAFKA-3284) Consider removing beta label in security documentation

2016-12-22 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3284: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

2016-12-22 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15770284#comment-15770284 ] Guozhang Wang commented on KAFKA-4468: -- Since window_size for a specific window object is static and

[jira] [Updated] (KAFKA-3587) LogCleaner fails due to incorrect offset map computation on a replica

2016-12-21 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3587: - Fix Version/s: 0.9.0.2 > LogCleaner fails due to incorrect offset map computation on a replica >

[jira] [Updated] (KAFKA-3564) Count metric always increments by 1.0

2016-12-21 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-3564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3564: - Resolution: Not A Bug Status: Resolved (was: Patch Available) Closing as not a bug for

[jira] [Updated] (KAFKA-2620) Introduce Scalariform

2016-12-21 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2620: - Reviewer: Gwen Shapira > Introduce Scalariform > - > > Key:

[jira] [Commented] (KAFKA-2442) QuotasTest should not fail when cpu is busy

2016-12-21 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767720#comment-15767720 ] Guozhang Wang commented on KAFKA-2442: -- [~lindong] Is this still a valid issue? > QuotasTest should

[jira] [Commented] (KAFKA-2170) 10 LogTest cases failed for file.renameTo failed under windows

2016-12-21 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767712#comment-15767712 ] Guozhang Wang commented on KAFKA-2170: -- Is this PR still valid in tackling this issue?

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

2016-12-21 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767709#comment-15767709 ] Guozhang Wang commented on KAFKA-1194: -- Is this PR trying to tackle this issue at all?

[jira] [Updated] (KAFKA-2358) Cluster collection returning methods should never return null

2016-12-21 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2358: - Assignee: Stevo Slavic > Cluster collection returning methods should never return null >

[jira] [Commented] (KAFKA-2341) Need Standard Deviation Metrics in MetricsBench

2016-12-21 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15767672#comment-15767672 ] Guozhang Wang commented on KAFKA-2341: -- [~sebadiaz] Added you to the contributor list. > Need

[jira] [Updated] (KAFKA-2341) Need Standard Deviation Metrics in MetricsBench

2016-12-21 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2341: - Assignee: sebastien diaz > Need Standard Deviation Metrics in MetricsBench >

[jira] [Created] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

2016-12-20 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-4564: Summary: When the destination brokers are down or misconfigured in config, Streams should fail fast Key: KAFKA-4564 URL: https://issues.apache.org/jira/browse/KAFKA-4564

[jira] [Commented] (KAFKA-4198) Transient test failure: ConsumerBounceTest.testConsumptionWithBrokerFailures

2016-12-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15765468#comment-15765468 ] Guozhang Wang commented on KAFKA-4198: -- Saw another case of this failure, but with different

[jira] [Updated] (KAFKA-4540) Suspended tasks that are not assigned to the StreamThread need to be closed before new active and standby tasks are created

2016-12-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4540: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-4473) RecordCollector should handle retriable exceptions more strictly

2016-12-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4473: - Resolution: Fixed Fix Version/s: 0.10.2.0 Status: Resolved (was: Patch

[jira] [Created] (KAFKA-4559) Add a site search bar on the Web site

2016-12-19 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-4559: Summary: Add a site search bar on the Web site Key: KAFKA-4559 URL: https://issues.apache.org/jira/browse/KAFKA-4559 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-4534) StreamPartitionAssignor only ever updates the partitionsByHostState and metadataWithInternalTopics once.

2016-12-19 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4534: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-4539) StreamThread is not correctly creating StandbyTasks

2016-12-15 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4539: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Updated] (KAFKA-4539) StreamThread is not correctly creating StandbyTasks

2016-12-15 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4539: - Description: Fails because {{createStandbyTask(..)}} can return null if the topology for the

[jira] [Resolved] (KAFKA-4537) StreamPartitionAssignor incorrectly adds standby partitions to the partitionsByHostState map

2016-12-15 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4537. -- Resolution: Fixed Issue resolved by pull request 2254

[jira] [Commented] (KAFKA-4540) Suspended tasks that are not assigned to the StreamThread need to be closed before new active and standby tasks are created

2016-12-15 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15752887#comment-15752887 ] Guozhang Wang commented on KAFKA-4540: -- Thanks for the explanation. Makes sense. > Suspended tasks

[jira] [Resolved] (KAFKA-4529) tombstone may be removed earlier than it should

2016-12-15 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4529. -- Resolution: Fixed Marked as fixed for the 0.10.1.1 release process. > tombstone may be removed

[jira] [Commented] (KAFKA-4528) Failure in kafka.producer.ProducerTest.testAsyncSendCanCorrectlyFailWithTimeout

2016-12-14 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749479#comment-15749479 ] Guozhang Wang commented on KAFKA-4528: -- Another observed failure:

[jira] [Commented] (KAFKA-4540) Suspended tasks that are not assigned to the StreamThread need to be closed before new active and standby tasks are created

2016-12-14 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15749465#comment-15749465 ] Guozhang Wang commented on KAFKA-4540: -- Is this already resolved as part of

[jira] [Resolved] (KAFKA-4532) StateStores can be connected to the wrong source topic resulting in incorrect metadata returned from IQ

2016-12-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4532. -- Resolution: Fixed Issue resolved by pull request 2250

[jira] [Updated] (KAFKA-4509) Task reusage on rebalance fails for threads on same host

2016-12-13 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4509: - Resolution: Fixed Fix Version/s: 0.10.2.0 Status: Resolved (was: Patch

[jira] [Updated] (KAFKA-4516) When a CachingStateStore is closed it should clear its associated NamedCache. Subsequent queries should throw InvalidStateStoreException

2016-12-12 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4516: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Created] (KAFKA-4528) Failure in kafka.producer.ProducerTest.testAsyncSendCanCorrectlyFailWithTimeout

2016-12-12 Thread Guozhang Wang (JIRA)
Guozhang Wang created KAFKA-4528: Summary: Failure in kafka.producer.ProducerTest.testAsyncSendCanCorrectlyFailWithTimeout Key: KAFKA-4528 URL: https://issues.apache.org/jira/browse/KAFKA-4528

[jira] [Updated] (KAFKA-4510) StreamThread must finish rebalance in state PENDING_SHUTDOWN

2016-12-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4510: - Resolution: Fixed Fix Version/s: 0.10.2.0 Status: Resolved (was: Patch

[jira] [Updated] (KAFKA-4476) Kafka Streams gets stuck if metadata is missing

2016-12-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4476: - Resolution: Fixed Fix Version/s: 0.10.2.0 Status: Resolved (was: Patch

<    5   6   7   8   9   10   11   12   13   14   >