kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Eno Thereska <eno.there...@gmail.com>
Subject Re: Attempting to put a clean entry for key [...] into NamedCache [...] when it already contains a dirty entry for the same key
Date Sun, 04 Dec 2016 07:37:58 GMT
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.fenniak@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 ...


Mime
View raw message