[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Description:
Normally, when a task is mitigated to a new thread and no checkpoint file was
found under i
linyue li created KAFKA-7672:
Summary: The local state not fully restored after KafkaStream
rebalanced, resulting in data loss
Key: KAFKA-7672
URL: https://issues.apache.org/jira/browse/KAFKA-7672
Project
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Description:
Normally, when a task is mitigated to a new thread and no checkpoint file was
found under i
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Description:
Normally, when a task is mitigated to a new thread and no checkpoint file was
found under i
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Description:
Normally, when a task is mitigated to a new thread and no checkpoint file was
found under i
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Description:
Normally, when a task is mitigated to a new thread and no checkpoint file was
found under i
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Description:
Normally, when a task is mitigated to a new thread and no checkpoint file was
found under i
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Description:
Normally, when a task is mitigated to a new thread and no checkpoint file was
found under i
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Description:
Normally, when a task is mitigated to a new thread and no checkpoint file was
found under i
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Description:
Normally, when a task is mitigated to a new thread and no checkpoint file was
found under i
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Description:
Normally, when a task is mitigated to a new thread and no checkpoint file was
found under i
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Description:
Normally, when a task is mitigated to a new thread and no checkpoint file was
found under i
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Flags: Patch,Important
Reviewer: John Roesler
> The local state not fully restored after KafkaStre
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Description:
Normally, when a task is mitigated to a new thread and no checkpoint file was
found under i
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7672:
-
Description:
Normally, when a task is mitigated to a new thread and no checkpoint file was
found under i
[
https://issues.apache.org/jira/browse/KAFKA-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7443:
-
Description:
When restoring local state store from a changelog topic in EOS, kafka stream
will sometimes
[
https://issues.apache.org/jira/browse/KAFKA-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7443:
-
Attachment: KAFKA-7443.url
> OffsetOutOfRangeException in restoring state store from changelog topic when
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li reassigned KAFKA-7672:
Assignee: linyue li
> The local state not fully restored after KafkaStream rebalanced, resulting i
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706600#comment-16706600
]
linyue li commented on KAFKA-7672:
--
[~liquanpei] Ok, I will open a PR according to the f
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16706639#comment-16706639
]
linyue li commented on KAFKA-7672:
--
[~mjsax] I've not figured out the more suitable solu
[
https://issues.apache.org/jira/browse/KAFKA-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7443:
-
Fix Version/s: 2.1.1
> OffsetOutOfRangeException in restoring state store from changelog topic when
> st
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16740178#comment-16740178
]
linyue li commented on KAFKA-7672:
--
[~guozhang]
Sorry to not fully understand the not c
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16766723#comment-16766723
]
linyue li commented on KAFKA-7672:
--
[~guozhang] Thanks for the fix, and I'll validate it
linyue li created KAFKA-7443:
Summary: OffsetOutOfRangeException in restoring state store from
changelog topic when start offset of local checkpoint is smaller than that of
changelog topic
Key: KAFKA-7443
URL: https:
[
https://issues.apache.org/jira/browse/KAFKA-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7443:
-
Labels: feather (was: patch)
> OffsetOutOfRangeException in restoring state store from changelog topic w
[
https://issues.apache.org/jira/browse/KAFKA-7443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linyue li updated KAFKA-7443:
-
Description:
When restoring local state store from a changelog topic in EOS, kafka stream
will sometimes
26 matches
Mail list logo
