[jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16714312#comment-16714312 ] Guozhang Wang commented on KAFKA-7634: -- Haha it seems I've miss-expressed myself again. I was

[jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691135#comment-16691135 ] Guozhang Wang commented on KAFKA-7634: -- What I'd need to look at is the punctuate call inside your

[jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690159#comment-16690159 ] Eugen Feller commented on KAFKA-7634: - Sure, let me try what I can do. Code looks like this:  

[jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690116#comment-16690116 ] Guozhang Wang commented on KAFKA-7634: -- Could you share your code snippet around the punctuation

[jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690046#comment-16690046 ] Eugen Feller commented on KAFKA-7634: - [~guozhang] In the meantime I found that if I materialize the

[jira] [Commented] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

[ https://issues.apache.org/jira/browse/KAFKA-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690001#comment-16690001 ] Eugen Feller commented on KAFKA-7634: - Hi [~guozhang] Thanks a lot for your quick reply. I will give