[jira] [Commented] (KAFKA-8289) KTable, Long> can't be suppressed

2019-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833045#comment-16833045 ] ASF GitHub Bot commented on KAFKA-8289: --- bbejeck commented on pull request #6671: K

[jira] [Commented] (KAFKA-8317) ClassCastException using KTable.suppress()

2019-05-04 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833060#comment-16833060 ] Andrew commented on KAFKA-8317: --- [~vvcephei] Here is the code snippet   ```     private

[jira] [Comment Edited] (KAFKA-8317) ClassCastException using KTable.suppress()

2019-05-04 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833060#comment-16833060 ] Andrew edited comment on KAFKA-8317 at 5/4/19 1:27 PM: --- [~vvcephei]

[jira] [Comment Edited] (KAFKA-8317) ClassCastException using KTable.suppress()

2019-05-04 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833060#comment-16833060 ] Andrew edited comment on KAFKA-8317 at 5/4/19 1:29 PM: --- [~vvcephei]

[jira] [Comment Edited] (KAFKA-8317) ClassCastException using KTable.suppress()

2019-05-04 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833060#comment-16833060 ] Andrew edited comment on KAFKA-8317 at 5/4/19 1:32 PM: --- [~vvcephei]

[jira] [Commented] (KAFKA-8323) Memory leak of BloomFilter Rocks object

2019-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833076#comment-16833076 ] ASF GitHub Bot commented on KAFKA-8323: --- bbejeck commented on pull request #6676: K

[jira] [Commented] (KAFKA-8323) Memory leak of BloomFilter Rocks object

2019-05-04 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8323?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833083#comment-16833083 ] Bill Bejeck commented on KAFKA-8323: cherry-picked [https://github.com/apache/kafka/p

[jira] [Updated] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

2019-05-04 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Attachment: code.java > Cannot pass Materialized into a join operation - hence cant set retention > period ind

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

2019-05-04 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833088#comment-16833088 ] Andrew edited comment on KAFKA-8315 at 5/4/19 3:51 PM: --- Ive attache

[jira] [Commented] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

2019-05-04 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833088#comment-16833088 ] Andrew commented on KAFKA-8315: --- Ive attached my code: * I have logging in the ValueJoiner

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

2019-05-04 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833088#comment-16833088 ] Andrew edited comment on KAFKA-8315 at 5/4/19 3:53 PM: --- Ive attache

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

2019-05-04 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833088#comment-16833088 ] Andrew edited comment on KAFKA-8315 at 5/4/19 3:53 PM: --- Ive attache

[jira] [Commented] (KAFKA-8306) Ensure consistency of checkpointed log start offset and current log end offset

2019-05-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833159#comment-16833159 ] ASF GitHub Bot commented on KAFKA-8306: --- hachikuji commented on pull request #6652:

[jira] [Commented] (KAFKA-8315) Cannot pass Materialized into a join operation - hence cant set retention period independent of grace

2019-05-04 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833161#comment-16833161 ] Andrew commented on KAFKA-8315: --- I have run a join by removing the timestamp transform and

[jira] [Resolved] (KAFKA-8306) Ensure consistency of checkpointed log start offset and current log end offset

2019-05-04 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8306. Resolution: Fixed Fix Version/s: 2.2.1 2.1.2 2.

[jira] [Commented] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

2019-05-04 Thread yanrui (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833182#comment-16833182 ] yanrui commented on KAFKA-7697: --- [~rsivaram] in 2.1.1 > Possible deadlock in kafka.cluste

[jira] [Issue Comment Deleted] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

2019-05-04 Thread yanrui (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yanrui updated KAFKA-7697: -- Comment: was deleted (was: [~rsivaram] in 2.1.1 ) > Possible deadlock in kafka.cluster.Partition > ---

[jira] [Updated] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

2019-05-04 Thread yanrui (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yanrui updated KAFKA-7697: -- Attachment: kafka_jstack.txt > Possible deadlock in kafka.cluster.Partition > -

[jira] [Commented] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

2019-05-04 Thread yanrui (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833183#comment-16833183 ] yanrui commented on KAFKA-7697: --- [~rsivaram] I have put file called kafka_jstack.txt which

[jira] [Comment Edited] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

2019-05-04 Thread little brother ma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16808327#comment-16808327 ] little brother ma edited comment on KAFKA-7697 at 5/5/19 1:47 AM: -

[jira] [Comment Edited] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

2019-05-04 Thread little brother ma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16808327#comment-16808327 ] little brother ma edited comment on KAFKA-7697 at 5/5/19 1:49 AM: -

[jira] [Commented] (KAFKA-7697) Possible deadlock in kafka.cluster.Partition

2019-05-04 Thread yanrui (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16833193#comment-16833193 ] yanrui commented on KAFKA-7697: --- [~rsivaram]This problem usually occurs with kafka and zk b

[jira] [Updated] (KAFKA-8225) Handle conflicting static member id

2019-05-04 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8225: --- Summary: Handle conflicting static member id (was: handle conflicting static member id) > Handle co