Hi Mathieu, I'm trying to make sense of the rather long stack trace in the gist you provided. Can you possibly share your streams topology with us?
Thanks, Damian On Mon, 5 Dec 2016 at 14:14 Mathieu Fenniak <mathieu.fenn...@replicon.com> wrote: > Hi Eno, > > This exception occurred w/ trunk @ e43bbce (current as-of Saturday). I was > bit by KAFKA-4311 (I believe) when trying to upgrade to 0.10.1.0, so with > that issue now resolved I thought I'd check trunk out to see if any other > issues remain. > > Mathieu > > > On Sun, Dec 4, 2016 at 12:37 AM, Eno Thereska <eno.there...@gmail.com> > wrote: > > > Hi Mathieu, > > > > What version of Kafka are you using? There was recently a fix that went > > into trunk, just checking if you're using an older version. > > (to make forward progress you can turn the cache off, like this: > > streamsConfiguration.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, > > 0); > > ) > > > > Thanks > > Eno > > > On 4 Dec 2016, at 03:47, Mathieu Fenniak <mathieu.fenn...@replicon.com > > > > wrote: > > > > > > Hey all, > > > > > > I've just been running a quick test of my kafka-streams application on > > the > > > latest Kafka trunk (@e43bbce), and came across this error. I was > > wondering > > > if anyone has seen this error before, have any thoughts on what might > > cause > > > it, or can suggest a direction to investigate it further. > > > > > > Full exception: > > > https://gist.github.com/mfenniak/509fb82dfcfda79a21cfc1b07dafa89c > > > > > > java.lang.IllegalStateException: Attempting to put a clean entry for > key > > > [urn:replicon-tenant:strprc971e3ca9:timesheet:97c0ce25-e039-4e8b-9f2c- > > d43f0668b755] > > > into NamedCache [0_0-TimesheetNonBillableHours] when it already > > contains a > > > dirty entry for the same key > > > at > > > org.apache.kafka.streams.state.internals.NamedCache. > > put(NamedCache.java:124) > > > at > > > org.apache.kafka.streams.state.internals.ThreadCache. > > put(ThreadCache.java:120) > > > at > > > org.apache.kafka.streams.state.internals.CachingKeyValueStore.get( > > CachingKeyValueStore.java:146) > > > at > > > org.apache.kafka.streams.state.internals.CachingKeyValueStore.get( > > CachingKeyValueStore.java:133) > > > at > > > org.apache.kafka.streams.kstream.internals.KTableAggregate$ > > KTableAggregateValueGetter.get(KTableAggregate.java:128) > > > at > > > org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$ > > KTableKTableLeftJoinProcessor.process(KTableKTableLeftJoin.java:81) > > > at > > > org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$ > > KTableKTableLeftJoinProcessor.process(KTableKTableLeftJoin.java:54) > > > at > > > org.apache.kafka.streams.processor.internals.ProcessorNode.process( > > ProcessorNode.java:82) > > > ... more ... > > > > >
