kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Damian Guy <damian....@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 Mon, 05 Dec 2016 15:36:52 GMT
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.fenniak@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.thereska@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.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
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message