[jira] [Created] (KAFKA-8315) Cannot pass Materialized into a join operation

2019-05-02 Thread Andrew (JIRA)
Andrew created KAFKA-8315: - Summary: Cannot pass Materialized into a join operation Key: KAFKA-8315 URL: https://issues.apache.org/jira/browse/KAFKA-8315 Project: Kafka Issue Type: Bug Re

[jira] [Commented] (KAFKA-8315) Cannot pass Materialized into a join operation

2019-05-02 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831735#comment-16831735 ] Andrew commented on KAFKA-8315: --- Ok, thanks. However, I thought retention period was mean

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation

2019-05-02 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831735#comment-16831735 ] Andrew edited comment on KAFKA-8315 at 5/2/19 4:27 PM: --- Ok, thanks.

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation

2019-05-02 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831735#comment-16831735 ] Andrew edited comment on KAFKA-8315 at 5/2/19 4:28 PM: --- Ok, thanks.

[jira] [Commented] (KAFKA-8315) Cannot pass Materialized into a join operation

2019-05-02 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831747#comment-16831747 ] Andrew commented on KAFKA-8315: --- I should also mention my use case from the original slack

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation

2019-05-02 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831747#comment-16831747 ] Andrew edited comment on KAFKA-8315 at 5/2/19 4:39 PM: --- I should al

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation

2019-05-02 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831747#comment-16831747 ] Andrew edited comment on KAFKA-8315 at 5/2/19 4:40 PM: --- I should al

[jira] [Comment Edited] (KAFKA-8315) Cannot pass Materialized into a join operation

2019-05-02 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831747#comment-16831747 ] Andrew edited comment on KAFKA-8315 at 5/2/19 4:53 PM: --- I should al

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

2019-05-02 Thread Andrew (JIRA)
Andrew created KAFKA-8317: - Summary: ClassCastException using KTable.suppress() Key: KAFKA-8317 URL: https://issues.apache.org/jira/browse/KAFKA-8317 Project: Kafka Issue Type: Bug Report

[jira] [Updated] (KAFKA-8315) Cannot pass Materialized into a join operation

2019-05-02 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Description: The documentation says to use `Materialized` not `JoinWindows.until()` ([https://kafka.apache.org

[jira] [Updated] (KAFKA-8315) Cannot pass Materialized into a join operation

2019-05-02 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Description: The documentation says to use `Materialized` not `JoinWindows.until()` ([https://kafka.apache.org

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

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

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

2019-05-03 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832325#comment-16832325 ] Andrew commented on KAFKA-8315: --- The fudge factor is the \{windowstore.changelog.additional

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

2019-05-03 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832325#comment-16832325 ] Andrew edited comment on KAFKA-8315 at 5/3/19 1:03 PM: --- The fudge f

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

2019-05-03 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832543#comment-16832543 ] Andrew commented on KAFKA-8315: --- [~vvcephei] Ive been struggling with this today. * I h

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

2019-05-03 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832543#comment-16832543 ] Andrew edited comment on KAFKA-8315 at 5/3/19 2:38 PM: --- [~vvcephei]

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

2019-05-03 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832543#comment-16832543 ] Andrew edited comment on KAFKA-8315 at 5/3/19 2:38 PM: --- [~vvcephei]

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

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

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

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

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

2019-05-03 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832577#comment-16832577 ] Andrew commented on KAFKA-8315: --- [~vvcephei] Update I ran using grace = 20D and I see recor

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

2019-05-03 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832577#comment-16832577 ] Andrew edited comment on KAFKA-8315 at 5/3/19 3:26 PM: --- [~vvcephei]

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

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

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

2019-05-03 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832577#comment-16832577 ] Andrew edited comment on KAFKA-8315 at 5/3/19 6:21 PM: --- [~vvcephei]

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

2019-05-03 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832577#comment-16832577 ] Andrew edited comment on KAFKA-8315 at 5/3/19 6:34 PM: --- [~vvcephei]

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

2019-05-03 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832577#comment-16832577 ] Andrew edited comment on KAFKA-8315 at 5/3/19 6:54 PM: --- [~vvcephei]

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

2019-05-03 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832577#comment-16832577 ] Andrew edited comment on KAFKA-8315 at 5/3/19 6:54 PM: --- [~vvcephei]

[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] [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-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] [Commented] (KAFKA-8317) ClassCastException using KTable.suppress()

2019-05-08 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835390#comment-16835390 ] Andrew commented on KAFKA-8317: --- Ok thanks for the reply. I will try this later. What surpr

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

2019-05-08 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835391#comment-16835391 ] Andrew commented on KAFKA-8317: --- Ok thanks for the reply. I will try this later. What surpr

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

2019-05-08 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835784#comment-16835784 ] Andrew commented on KAFKA-8315: --- After a lot of investigation, we think this issue is down

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

2019-05-08 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835784#comment-16835784 ] Andrew edited comment on KAFKA-8315 at 5/8/19 5:54 PM: --- After a lot

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

2019-05-09 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836278#comment-16836278 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:43 AM: Ok, so it

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

2019-05-09 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836278#comment-16836278 ] Andrew commented on KAFKA-8315: --- Ok, so it should work as I had previously hoped, so maybe

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

2019-05-09 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836278#comment-16836278 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:56 AM: Ok, so it

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

2019-05-09 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836278#comment-16836278 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:57 AM: Ok, so it

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

2019-05-09 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836278#comment-16836278 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:57 AM: Ok, so it

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

2019-05-09 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836278#comment-16836278 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:58 AM: [~vvcephe

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

2019-05-09 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836735#comment-16836735 ] Andrew commented on KAFKA-8315: --- Thanks [~ableegoldman] and [~vvcephei]. I have today trie

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

2019-05-09 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836735#comment-16836735 ] Andrew edited comment on KAFKA-8315 at 5/9/19 9:59 PM: --- Thanks [~ab

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

2019-05-09 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836735#comment-16836735 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:03 PM: Thanks [~

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

2019-05-09 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836735#comment-16836735 ] Andrew edited comment on KAFKA-8315 at 5/9/19 10:04 PM: Thanks [~

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

2019-05-10 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837086#comment-16837086 ] Andrew commented on KAFKA-8315: --- [~ableegoldman] Can I sanity check my understanding here.

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

2019-05-10 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:26 AM: [~ableego

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

2019-05-10 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:27 AM: [~ableego

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

2019-05-10 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:27 AM: [~ableego

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

2019-05-10 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:31 AM: [~ableego

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

2019-05-10 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:32 AM: [~ableego

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

2019-05-10 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:40 AM: [~ableego

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

2019-05-10 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:42 AM: [~ableego

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

2019-05-10 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:42 AM: [~ableego

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

2019-05-10 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:42 AM: [~ableego

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

2019-05-10 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:43 AM: [~ableego

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

2019-05-10 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:47 AM: [~ableego

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

2019-05-10 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16837086#comment-16837086 ] Andrew edited comment on KAFKA-8315 at 5/10/19 9:48 AM: [~ableego

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

2019-05-11 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838012#comment-16838012 ] Andrew commented on KAFKA-8315: --- [~ableegoldman] Right, I see what you mean, this loop only

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

2019-05-13 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838012#comment-16838012 ] Andrew edited comment on KAFKA-8315 at 5/13/19 7:10 AM: [~ableego

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

2019-05-13 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838471#comment-16838471 ] Andrew commented on KAFKA-8315: --- [~vvcephei] [~ableegoldman] I was just looking at the unit

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

2019-05-13 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838471#comment-16838471 ] Andrew edited comment on KAFKA-8315 at 5/13/19 12:52 PM: - [~vvcep

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

2019-05-13 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838550#comment-16838550 ] Andrew commented on KAFKA-8315: --- This test appears to work ok [https://github.com/the4tham

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

2019-05-13 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838550#comment-16838550 ] Andrew edited comment on KAFKA-8315 at 5/13/19 1:48 PM: This test

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

2019-05-13 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838550#comment-16838550 ] Andrew edited comment on KAFKA-8315 at 5/13/19 1:48 PM: This test

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

2019-05-13 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838550#comment-16838550 ] Andrew edited comment on KAFKA-8315 at 5/13/19 1:50 PM: This test

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

2019-05-13 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838565#comment-16838565 ] Andrew commented on KAFKA-8315: --- This is the test enhanced to use timestamp extraction, and

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

2019-05-13 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838565#comment-16838565 ] Andrew edited comment on KAFKA-8315 at 5/13/19 2:17 PM: This is t

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

2019-05-13 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838565#comment-16838565 ] Andrew edited comment on KAFKA-8315 at 5/13/19 3:45 PM: This is t

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

2019-05-13 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838565#comment-16838565 ] Andrew edited comment on KAFKA-8315 at 5/13/19 3:52 PM: This is t

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

2019-05-13 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838783#comment-16838783 ] Andrew commented on KAFKA-8315: --- Thanks [~vvcephei], I am running the unit tests in the kaf

[jira] [Updated] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Summary: Historical join issues (was: Cannot pass Materialized into a join operation - hence cant set retentio

[jira] [Updated] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Description: The problem we are experiencing is that we cannot reliably perform simple joins over pre-populate

[jira] [Updated] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Description: The problem we are experiencing is that we cannot reliably perform simple joins over pre-populate

[jira] [Updated] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Description: The problem we are experiencing is that we cannot reliably perform simple joins over pre-populate

[jira] [Updated] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Description: The problem we are experiencing is that we cannot reliably perform simple joins over pre-populate

[jira] [Updated] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Description: The problem we are experiencing is that we cannot reliably perform simple joins over pre-populate

[jira] [Updated] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Description: The problem we are experiencing is that we cannot reliably perform simple joins over pre-populate

[jira] [Updated] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Description: The problem we are experiencing is that we cannot reliably perform simple joins over pre-populate

[jira] [Updated] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Description: The problem we are experiencing is that we cannot reliably perform simple joins over pre-populate

[jira] [Updated] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Description: The problem we are experiencing is that we cannot reliably perform simple joins over pre-populate

[jira] [Updated] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Description: The problem we are experiencing is that we cannot reliably perform simple joins over pre-populate

[jira] [Updated] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew updated KAFKA-8315: -- Description: The problem we are experiencing is that we cannot reliably perform simple joins over pre-populate

[jira] [Commented] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16839703#comment-16839703 ] Andrew commented on KAFKA-8315: --- I constructed a super-ugly workaround for my \{{join-examp

[jira] [Commented] (KAFKA-8315) Historical join issues

2019-05-14 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16839711#comment-16839711 ] Andrew commented on KAFKA-8315: --- I constructed a super-ugly workaround for my \{{join-examp

[jira] [Commented] (KAFKA-8315) Historical join issues

2019-05-15 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16840541#comment-16840541 ] Andrew commented on KAFKA-8315: --- [~vvcephei] [~ableegoldman] I have constructed an integrat

[jira] [Commented] (KAFKA-8315) Historical join issues

2019-05-16 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841213#comment-16841213 ] Andrew commented on KAFKA-8315: --- [~vvcephei] [~ableegoldman] Using the integration test I t

[jira] [Commented] (KAFKA-8315) Historical join issues

2019-05-16 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841273#comment-16841273 ] Andrew commented on KAFKA-8315: --- Ha!, you are absolutely right. Maybe I didn't understand t

[jira] [Commented] (KAFKA-8315) Historical join issues

2019-05-16 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841449#comment-16841449 ] Andrew commented on KAFKA-8315: --- [~mjsax] [~vvcephei] [~ableegoldman] Thanks for your help

[jira] [Commented] (KAFKA-8315) Historical join issues

2019-05-16 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841611#comment-16841611 ] Andrew commented on KAFKA-8315: --- Well, Im not sure that just fixing the start is sufficient

[jira] [Comment Edited] (KAFKA-8315) Historical join issues

2019-05-16 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841611#comment-16841611 ] Andrew edited comment on KAFKA-8315 at 5/16/19 6:16 PM: Well, Im

[jira] [Comment Edited] (KAFKA-8315) Historical join issues

2019-05-16 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841611#comment-16841611 ] Andrew edited comment on KAFKA-8315 at 5/16/19 6:28 PM: Well, Im

[jira] [Comment Edited] (KAFKA-8315) Historical join issues

2019-05-16 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841611#comment-16841611 ] Andrew edited comment on KAFKA-8315 at 5/16/19 6:29 PM: Well, Im

[jira] [Comment Edited] (KAFKA-8315) Historical join issues

2019-05-16 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841611#comment-16841611 ] Andrew edited comment on KAFKA-8315 at 5/16/19 6:30 PM: Well, Im

[jira] [Comment Edited] (KAFKA-8315) Historical join issues

2019-05-16 Thread Andrew (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841611#comment-16841611 ] Andrew edited comment on KAFKA-8315 at 5/16/19 6:32 PM: Well, Im

  1   2   >