[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16034356#comment-16034356
]
Lukas Gemela commented on KAFKA-5154:
-
[~guozhang] no worries, thank you for the fix,
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011966#comment-16011966
]
Lukas Gemela edited comment on KAFKA-5154 at 5/16/17 8:37 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011982#comment-16011982
]
Lukas Gemela edited comment on KAFKA-5154 at 5/16/17 8:33 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Gemela updated KAFKA-5154:
Attachment: clio_afa596e9b809.gz
[~guozhang] full logs attached.
> Kafka Streams throws NPE during
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011966#comment-16011966
]
Lukas Gemela commented on KAFKA-5154:
-
[~mjsax]
I really can't give you any ultimate
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011222#comment-16011222
]
Lukas Gemela edited comment on KAFKA-5242 at 5/15/17 7:48 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011222#comment-16011222
]
Lukas Gemela commented on KAFKA-5242:
-
We used two stream threads, like I said we have
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010974#comment-16010974
]
Lukas Gemela edited comment on KAFKA-5242 at 5/15/17 5:50 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010974#comment-16010974
]
Lukas Gemela edited comment on KAFKA-5242 at 5/15/17 5:50 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010974#comment-16010974
]
Lukas Gemela edited comment on KAFKA-5242 at 5/15/17 5:48 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Gemela updated KAFKA-5242:
Attachment: clio_170511.log
> add max_number _of_retries to exponential backoff strategy
> -
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010974#comment-16010974
]
Lukas Gemela commented on KAFKA-5242:
-
[~mjsax] by multiple instances you mean multipl
[
https://issues.apache.org/jira/browse/KAFKA-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Gemela updated KAFKA-5240:
Priority: Minor (was: Major)
> Make persistent checkpointedOffsets optionable
> ---
[
https://issues.apache.org/jira/browse/KAFKA-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Gemela updated KAFKA-5240:
Description:
By looking at the ProcessorStateManager class kafka streams library tries to
persist c
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Gemela updated KAFKA-5242:
Priority: Minor (was: Major)
> add max_number _of_retries to exponential backoff strategy
> ---
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Gemela updated KAFKA-5242:
Description:
>From time to time, during relabance we are getting a lot of exceptions saying
{code}
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Gemela updated KAFKA-5242:
Attachment: (was: clio_170511.log)
> add max_number _of_retries to exponential backoff strategy
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Gemela updated KAFKA-5242:
Summary: add max_number _of_retries to exponential backoff strategy (was:
state task directory lock
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Gemela updated KAFKA-5242:
Issue Type: Improvement (was: Bug)
> state task directory locked forever
>
[
https://issues.apache.org/jira/browse/KAFKA-5242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Gemela updated KAFKA-5242:
Description:
>From time to time, during relabance we are getting a lot of exceptions saying
{code}
[
https://issues.apache.org/jira/browse/KAFKA-5240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Gemela updated KAFKA-5240:
Description:
By looking at the ProcessorStateManager class kafka streams library tries to
persist c
Lukas Gemela created KAFKA-5242:
---
Summary: state task directory locked forever
Key: KAFKA-5242
URL: https://issues.apache.org/jira/browse/KAFKA-5242
Project: Kafka
Issue Type: Bug
Com
Lukas Gemela created KAFKA-5240:
---
Summary: Make persistent checkpointedOffsets optionable
Key: KAFKA-5240
URL: https://issues.apache.org/jira/browse/KAFKA-5240
Project: Kafka
Issue Type: Improv
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16010143#comment-16010143
]
Lukas Gemela commented on KAFKA-5154:
-
[~mjsax] logs attached (clio_reduced)
It's jus
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Gemela updated KAFKA-5154:
Attachment: clio_reduced.gz
> Kafka Streams throws NPE during rebalance
> --
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16002457#comment-16002457
]
Lukas Gemela commented on KAFKA-5154:
-
today we reproduced the issue on two of our nod
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001501#comment-16001501
]
Lukas Gemela commented on KAFKA-5154:
-
[~guozhang] Yes I know log does not contain NPE
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Gemela updated KAFKA-5154:
Attachment: clio.txt.gz
> Kafka Streams throws NPE during rebalance
> --
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15997141#comment-15997141
]
Lukas Gemela commented on KAFKA-5154:
-
I just found the exception from my previous com
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996995#comment-15996995
]
Lukas Gemela edited comment on KAFKA-5154 at 5/4/17 4:26 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15996995#comment-15996995
]
Lukas Gemela commented on KAFKA-5154:
-
I wasnt able to reproduce the issue yet, but I
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15994646#comment-15994646
]
Lukas Gemela commented on KAFKA-5154:
-
Ok I've made it running with kafka streams tag
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15994475#comment-15994475
]
Lukas Gemela commented on KAFKA-5154:
-
[~mjsax] should not be a problem, I can make it
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15993902#comment-15993902
]
Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 11:10 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15993902#comment-15993902
]
Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 10:56 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15993902#comment-15993902
]
Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 10:35 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15993902#comment-15993902
]
Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 10:34 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15993902#comment-15993902
]
Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 10:33 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15993902#comment-15993902
]
Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 10:33 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15993902#comment-15993902
]
Lukas Gemela edited comment on KAFKA-5154 at 5/2/17 10:27 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15993902#comment-15993902
]
Lukas Gemela commented on KAFKA-5154:
-
Hi,
we have a kafka streams app consuming from
Lukas Gemela created KAFKA-5154:
---
Summary: Kafka Streams throws NPE during rebalance
Key: KAFKA-5154
URL: https://issues.apache.org/jira/browse/KAFKA-5154
Project: Kafka
Issue Type: Bug
42 matches
Mail list logo
