[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-04-18 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16821530#comment-16821530 ] Matthias J. Sax commented on KAFKA-7672: [~guozhang] Do  you think it might be worth to backport

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16775806#comment-16775806 ] ASF GitHub Bot commented on KAFKA-7672: --- guozhangwang commented on pull request #6115: KAFKA-7672

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-02-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16775500#comment-16775500 ] ASF GitHub Bot commented on KAFKA-7672: --- guozhangwang commented on pull request #6113: KAFKA-7672:

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-02-12 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16766723#comment-16766723 ] linyue li commented on KAFKA-7672: -- [~guozhang] Thanks for the fix, and I'll validate it once it's

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-02-07 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16763230#comment-16763230 ] Guozhang Wang commented on KAFKA-7672: -- [~linyli] I think if we can get both [~bchen225242]'s PR and

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-02-06 Thread Ziming Dong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16762318#comment-16762318 ] Ziming Dong commented on KAFKA-7672: [~linyli], I see, each time `restore` function only `poll` once.

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-02-06 Thread Ziming Dong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16762298#comment-16762298 ] Ziming Dong commented on KAFKA-7672: [~linyli], I see, there is a `runLoop` in `StreamThread`, and

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-02-06 Thread Ziming Dong (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16761686#comment-16761686 ] Ziming Dong commented on KAFKA-7672: [~linyli], I also met this issue, but I find that if the program

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-01-11 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16740178#comment-16740178 ] linyue li commented on KAFKA-7672: -- [~guozhang] Sorry to not fully understand the not closed restoring

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-01-09 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738970#comment-16738970 ] ASF GitHub Bot commented on KAFKA-7672: --- abbccdda commented on pull request #6115: KAFKA-7672 :

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-01-09 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738973#comment-16738973 ] Boyang Chen commented on KAFKA-7672: Thanks for the thorough investigation and summary here

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-01-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738897#comment-16738897 ] Guozhang Wang commented on KAFKA-7672: -- [~bchen225242] I read your new fix, and it was not what I've

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-01-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738896#comment-16738896 ] Guozhang Wang commented on KAFKA-7672: -- [~linyli] [~bchen225242] While trying to prepare a PR for

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-01-06 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16735422#comment-16735422 ] Boyang Chen commented on KAFKA-7672: [~guozhang] Thanks for the explanation! It's a little bit

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-01-06 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16735387#comment-16735387 ] Guozhang Wang commented on KAFKA-7672: -- Ah I see you point. I think the root cause of the second

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-01-04 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16734504#comment-16734504 ] Boyang Chen commented on KAFKA-7672: [~guozhang] Yes the second issue. So since

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-01-04 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16734491#comment-16734491 ] Guozhang Wang commented on KAFKA-7672: -- [~bchen225242] are you referring to the fix of the second

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2019-01-04 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16734415#comment-16734415 ] Boyang Chen commented on KAFKA-7672: [~guozhang] Are you suggesting sth similar to this? 

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-12-02 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706754#comment-16706754 ] Guozhang Wang commented on KAFKA-7672: -- [~linyli] Thanks for reporting the issues! I suggest you

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-12-02 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706639#comment-16706639 ] linyue li commented on KAFKA-7672: -- [~mjsax] I've not figured out the more suitable solution for race

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-12-02 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706634#comment-16706634 ] Matthias J. Sax commented on KAFKA-7672: [~linyli] Thanks for picking this up. However, I agree

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-12-02 Thread linyue li (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16706600#comment-16706600 ] linyue li commented on KAFKA-7672: -- [~liquanpei] Ok, I will open a PR according to the fix given in my

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-12-01 Thread Liquan Pei (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705999#comment-16705999 ] Liquan Pei commented on KAFKA-7672: --- [~linyli] Do you plan to work on a fix for this issue?  cc

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-26 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16698803#comment-16698803 ] Boyang Chen commented on KAFKA-7672: Thanks Linyue for reporting and reproducing the bug! In fact, we

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

2018-11-25 Thread Matthias J. Sax (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16698502#comment-16698502 ] Matthias J. Sax commented on KAFKA-7672: Thanks for reporting this and for the detailed analysis!