Re: windowed store excessive memory consumption

2017-09-28 Thread Matthias J. Sax
Thanks! On 9/28/17 2:19 AM, Stas Chizhov wrote: > Sure. Here we go: https://issues.apache.org/jira/browse/KAFKA-5985 > > 2017-09-28 0:23 GMT+02:00 Matthias J. Sax : > I have a feeling that it would be helpful to add this to documentation examples as well as javadocs for all methods th

Re: windowed store excessive memory consumption

2017-09-28 Thread Stas Chizhov
Sure. Here we go: https://issues.apache.org/jira/browse/KAFKA-5985 2017-09-28 0:23 GMT+02:00 Matthias J. Sax : > >> I have a feeling that it would be helpful to add this to documentation > >> examples as well as javadocs for all methods that do return iterators. > > That makes sense. Can you cre

Re: windowed store excessive memory consumption

2017-09-27 Thread Matthias J. Sax
>> I have a feeling that it would be helpful to add this to documentation >> examples as well as javadocs for all methods that do return iterators. That makes sense. Can you create a JIRA for this? Thanks. -Matthias On 9/27/17 2:54 PM, Stas Chizhov wrote: > Thanks, that comment actually mad its

Re: windowed store excessive memory consumption

2017-09-27 Thread Stas Chizhov
Thanks, that comment actually mad its way to the documentation already. Apparently none of that was related. It was a leak - I was not closing an iterator that was returned by https://kafka.apache.org/0110/javadoc/org/apache/kafka/streams/state/ReadOnlyWindowStore.html#fetch(K,%20long,%20long) Meth

Re: windowed store excessive memory consumption

2017-09-27 Thread Ted Yu
Have you seen this comment ? https://issues.apache.org/jira/browse/KAFKA-5122?focusedCommentId=15984467&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-15984467 On Wed, Sep 27, 2017 at 12:44 PM, Stas Chizhov wrote: > Hi, > > I am running a simple kafka streams app