[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17139963#comment-17139963 ] Mateusz Jadczyk commented on KAFKA-9891: LGTM thanks for looking into it and maki

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17124787#comment-17124787 ] Mateusz Jadczyk commented on KAFKA-9891: [~bchen225242] well, it shouldn't occur

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123544#comment-17123544 ] Mateusz Jadczyk commented on KAFKA-9891: The reason we need at least one material

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17123542#comment-17123542 ] Mateusz Jadczyk commented on KAFKA-9891: [~bchen225242] yes, it should be materia

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120333#comment-17120333 ] Mateusz Jadczyk commented on KAFKA-9891: On trunk I can't seem to reproduce this

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120253#comment-17120253 ] Mateusz Jadczyk commented on KAFKA-9891: I think I wanted to be sure that keyOne

[jira] [Comment Edited] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120253#comment-17120253 ] Mateusz Jadczyk edited comment on KAFKA-9891 at 5/30/20, 1:57 PM: -

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117509#comment-17117509 ] Mateusz Jadczyk commented on KAFKA-9891: [~mjsax] If I'm not mistaken, these logs

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115954#comment-17115954 ] Mateusz Jadczyk commented on KAFKA-9891: [~mjsax] if this is true  > _Restart ins

[jira] [Comment Edited] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115366#comment-17115366 ] Mateusz Jadczyk edited comment on KAFKA-9891 at 5/24/20, 4:35 PM: -

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115366#comment-17115366 ] Mateusz Jadczyk commented on KAFKA-9891: Maybe this could make this test more rel

[jira] [Updated] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mateusz Jadczyk updated KAFKA-9891: --- Attachment: failedtest3 failedtest3_bug > Invalid state store content after t

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115352#comment-17115352 ] Mateusz Jadczyk commented on KAFKA-9891: BTW in this test (_failedtest3_) it also

[jira] [Comment Edited] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115324#comment-17115324 ] Mateusz Jadczyk edited comment on KAFKA-9891 at 5/24/20, 2:35 PM: -

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115324#comment-17115324 ] Mateusz Jadczyk commented on KAFKA-9891: I think I reproduce it in  [https://gith

[jira] [Updated] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mateusz Jadczyk updated KAFKA-9891: --- Attachment: failedtest2 failedtest > Invalid state store content after task m

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110947#comment-17110947 ] Mateusz Jadczyk commented on KAFKA-9891: [~bchen225242] have you had time to look

[jira] [Comment Edited] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17102668#comment-17102668 ] Mateusz Jadczyk edited comment on KAFKA-9891 at 5/8/20, 3:23 PM: --

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17102668#comment-17102668 ] Mateusz Jadczyk commented on KAFKA-9891: Maybe I didn't. You can now find them in

[jira] [Updated] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mateusz Jadczyk updated KAFKA-9891: --- Attachment: tasks_assignment.txt state_store_operations.txt > Invalid state s

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17100135#comment-17100135 ] Mateusz Jadczyk commented on KAFKA-9891: I don't think I have enough knowledge to

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099743#comment-17099743 ] Mateusz Jadczyk commented on KAFKA-9891: [~bchen225242] Hi, is any follow-up plan

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17094313#comment-17094313 ] Mateusz Jadczyk commented on KAFKA-9891: Thanks for looking into it. I looked int

[jira] [Updated] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mateusz Jadczyk updated KAFKA-9891: --- Priority: Blocker (was: Critical) > Invalid state store content after task migration with ex

[jira] [Updated] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mateusz Jadczyk updated KAFKA-9891: --- Description: We have a simple command id deduplication mechanism (very similar to the one fr

[jira] [Created] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

Mateusz Jadczyk created KAFKA-9891: -- Summary: Invalid state store content after task migration with exactly_once and standby replicas Key: KAFKA-9891 URL: https://issues.apache.org/jira/browse/KAFKA-9891