[jira] [Created] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

Jamie Brandon created KAFKA-12594: - Summary: Self-join produces no ouput, and prevents other streams from producing output Key: KAFKA-12594 URL: https://issues.apache.org/jira/browse/KAFKA-12594 Proje

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312787#comment-17312787 ] Jamie Brandon commented on KAFKA-12594: --- Same behavior with this example - when th

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312797#comment-17312797 ] Jamie Brandon commented on KAFKA-12594: --- Slack discussion - https://confluentcomm

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312802#comment-17312802 ] Jamie Brandon commented on KAFKA-12594: --- I'm also noticing that when I just run th

[jira] [Comment Edited] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312802#comment-17312802 ] Jamie Brandon edited comment on KAFKA-12594 at 4/1/21, 1:16 AM: --

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312805#comment-17312805 ] Jamie Brandon commented on KAFKA-12594: --- With the identity and self-join, about 1

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312806#comment-17312806 ] Jamie Brandon commented on KAFKA-12594: --- I've tried setting MAX_TASK_IDLE_MS_CONFI

[jira] [Updated] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jamie Brandon updated KAFKA-12594: -- Attachment: logs.tar.gz > Self-join produces no ouput, and prevents other streams from produci

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312809#comment-17312809 ] Jamie Brandon commented on KAFKA-12594: --- Tried leaving it sitting for 20 minutes t

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313488#comment-17313488 ] Jamie Brandon commented on KAFKA-12594: --- The first example is a table-table join a

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313489#comment-17313489 ] Jamie Brandon commented on KAFKA-12594: --- Specifically, the reason that I filed thi

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313496#comment-17313496 ] Jamie Brandon commented on KAFKA-12594: --- Ok, here is the code I'm running now. {c

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313497#comment-17313497 ] Jamie Brandon commented on KAFKA-12594: --- Actually I see 998218 records in the 'acc

[jira] [Comment Edited] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313497#comment-17313497 ] Jamie Brandon edited comment on KAFKA-12594 at 4/2/21, 1:19 AM: --

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313505#comment-17313505 ] Jamie Brandon commented on KAFKA-12594: --- {code:bash} jamie@machine:~$ ps aux | gre

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313504#comment-17313504 ] Jamie Brandon commented on KAFKA-12594: --- Btw the repo at https://github.com/jamii

[jira] [Comment Edited] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313505#comment-17313505 ] Jamie Brandon edited comment on KAFKA-12594 at 4/2/21, 1:50 AM: --

[jira] [Comment Edited] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313505#comment-17313505 ] Jamie Brandon edited comment on KAFKA-12594 at 4/2/21, 1:54 AM: --

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313514#comment-17313514 ] Jamie Brandon commented on KAFKA-12594: --- I needed `strace -f` - there was some wra

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313518#comment-17313518 ] Jamie Brandon commented on KAFKA-12594: --- It seems like they both read the data. {

[jira] [Comment Edited] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313514#comment-17313514 ] Jamie Brandon edited comment on KAFKA-12594 at 4/2/21, 2:41 AM: --

[jira] [Commented] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313557#comment-17313557 ] Jamie Brandon commented on KAFKA-12594: --- This repros consistently on my laptop (ni

[jira] [Updated] (KAFKA-12594) Various simple examples produce no ouput, and prevent other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jamie Brandon updated KAFKA-12594: -- Summary: Various simple examples produce no ouput, and prevent other streams from producing ou

[jira] [Created] (KAFKA-12608) Simple identity pipeline sometimes loses data

Jamie Brandon created KAFKA-12608: - Summary: Simple identity pipeline sometimes loses data Key: KAFKA-12608 URL: https://issues.apache.org/jira/browse/KAFKA-12608 Project: Kafka Issue Type: B

[jira] [Updated] (KAFKA-12608) Simple identity pipeline sometimes loses data

[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jamie Brandon updated KAFKA-12608: -- Description: I'm running a very simple streams program that reads records from one topic into

[jira] [Commented] (KAFKA-12594) Various simple examples produce no ouput, and prevent other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17314100#comment-17314100 ] Jamie Brandon commented on KAFKA-12594: --- I filed a separate issue for the dropped

[jira] [Commented] (KAFKA-12608) Simple identity pipeline sometimes loses data

[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319919#comment-17319919 ] Jamie Brandon commented on KAFKA-12608: --- Everything is in the repo I linked above,

[jira] [Commented] (KAFKA-12608) Simple identity pipeline sometimes loses data

[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320463#comment-17320463 ] Jamie Brandon commented on KAFKA-12608: --- I tried with `--config retention.ms=-1` a

[jira] [Resolved] (KAFKA-12608) Simple identity pipeline sometimes loses data

[ https://issues.apache.org/jira/browse/KAFKA-12608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jamie Brandon resolved KAFKA-12608. --- Resolution: Invalid > Simple identity pipeline sometimes loses data > --

[jira] [Commented] (KAFKA-12594) Various simple examples produce no ouput, and prevent other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320464#comment-17320464 ] Jamie Brandon commented on KAFKA-12594: --- In light of https://issues.apache.org/jir

[jira] [Updated] (KAFKA-12594) Various simple examples produce no ouput, and prevent other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jamie Brandon updated KAFKA-12594: -- Attachment: screenshot_2021-04-13_12-10-31.png > Various simple examples produce no ouput, and

[jira] [Updated] (KAFKA-12594) Various simple examples produce no ouput, and prevent other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jamie Brandon updated KAFKA-12594: -- Attachment: screenshot_2021-04-13_12-10-19.png > Various simple examples produce no ouput, and

[jira] [Commented] (KAFKA-12594) Various simple examples produce no ouput, and prevent other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320481#comment-17320481 ] Jamie Brandon commented on KAFKA-12594: --- I verified in wireshark that no data is b

[jira] [Updated] (KAFKA-12594) Various simple examples produce no ouput, and prevent other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jamie Brandon updated KAFKA-12594: -- Attachment: screenshot_2021-04-13_12-13-04.png > Various simple examples produce no ouput, and

[jira] [Commented] (KAFKA-12594) Various simple examples produce no ouput, and prevent other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320484#comment-17320484 ] Jamie Brandon commented on KAFKA-12594: --- Same behavior if I modify the timestamps

[jira] [Commented] (KAFKA-12594) Various simple examples produce no ouput, and prevent other streams from producing output

[ https://issues.apache.org/jira/browse/KAFKA-12594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320487#comment-17320487 ] Jamie Brandon commented on KAFKA-12594: --- I've setup the same calculation and data