kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mathieu Fenniak <mathieu.fenn...@replicon.com>
Subject 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 03:47:32 GMT
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
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message