Created
December 4, 2016 03:43
-
-
Save mfenniak/509fb82dfcfda79a21cfc1b07dafa89c to your computer and use it in GitHub Desktop.
kafka-streams error w/ trunk @ e43bbce
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$KTableKTableJoinMergeProcessor.process(KTableKTableJoinMerger.java:52) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$KTableKTableJoinMergeProcessor.process(KTableKTableJoinMerger.java:49) | |
| at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:82) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinProcessor.process(KTableKTableLeftJoin.java:93) | |
| 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) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$KTableKTableJoinMergeProcessor.process(KTableKTableJoinMerger.java:52) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$KTableKTableJoinMergeProcessor.process(KTableKTableJoinMerger.java:49) | |
| at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:82) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinProcessor.process(KTableKTableLeftJoin.java:93) | |
| 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) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$KTableKTableJoinMergeProcessor.process(KTableKTableJoinMerger.java:52) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$KTableKTableJoinMergeProcessor.process(KTableKTableJoinMerger.java:49) | |
| at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:82) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinProcessor.process(KTableKTableLeftJoin.java:93) | |
| 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) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$KTableKTableJoinMergeProcessor.process(KTableKTableJoinMerger.java:52) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableJoinMerger$KTableKTableJoinMergeProcessor.process(KTableKTableJoinMerger.java:49) | |
| at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:82) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinProcessor.process(KTableKTableRightJoin.java:92) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinProcessor.process(KTableKTableRightJoin.java:54) | |
| at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:82) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.kstream.internals.ForwardingCacheFlushListener.apply(ForwardingCacheFlushListener.java:40) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.putAndMaybeForward(CachingKeyValueStore.java:94) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.access$000(CachingKeyValueStore.java:33) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore$1.apply(CachingKeyValueStore.java:81) | |
| at org.apache.kafka.streams.state.internals.NamedCache.flush(NamedCache.java:117) | |
| at org.apache.kafka.streams.state.internals.NamedCache.evict(NamedCache.java:205) | |
| at org.apache.kafka.streams.state.internals.ThreadCache.maybeEvict(ThreadCache.java:199) | |
| at org.apache.kafka.streams.state.internals.ThreadCache.put(ThreadCache.java:121) | |
| 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$KTableKTableLeftJoinValueGetter.get(KTableKTableLeftJoin.java:118) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinProcessor.process(KTableKTableRightJoin.java:81) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinProcessor.process(KTableKTableRightJoin.java:54) | |
| at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:82) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.kstream.internals.ForwardingCacheFlushListener.apply(ForwardingCacheFlushListener.java:40) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.putAndMaybeForward(CachingKeyValueStore.java:94) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.access$000(CachingKeyValueStore.java:33) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore$1.apply(CachingKeyValueStore.java:81) | |
| at org.apache.kafka.streams.state.internals.NamedCache.flush(NamedCache.java:117) | |
| at org.apache.kafka.streams.state.internals.NamedCache.evict(NamedCache.java:205) | |
| at org.apache.kafka.streams.state.internals.ThreadCache.maybeEvict(ThreadCache.java:199) | |
| at org.apache.kafka.streams.state.internals.ThreadCache.put(ThreadCache.java:121) | |
| 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$KTableKTableLeftJoinValueGetter.get(KTableKTableLeftJoin.java:118) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinValueGetter.get(KTableKTableLeftJoin.java:115) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinValueGetter.get(KTableKTableLeftJoin.java:115) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinProcessor.process(KTableKTableRightJoin.java:81) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinProcessor.process(KTableKTableRightJoin.java:54) | |
| at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:82) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.kstream.internals.ForwardingCacheFlushListener.apply(ForwardingCacheFlushListener.java:40) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.putAndMaybeForward(CachingKeyValueStore.java:94) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.access$000(CachingKeyValueStore.java:33) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore$1.apply(CachingKeyValueStore.java:81) | |
| at org.apache.kafka.streams.state.internals.NamedCache.flush(NamedCache.java:117) | |
| at org.apache.kafka.streams.state.internals.NamedCache.evict(NamedCache.java:205) | |
| at org.apache.kafka.streams.state.internals.ThreadCache.maybeEvict(ThreadCache.java:199) | |
| at org.apache.kafka.streams.state.internals.ThreadCache.put(ThreadCache.java:121) | |
| 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$KTableKTableLeftJoinValueGetter.get(KTableKTableLeftJoin.java:118) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinProcessor.process(KTableKTableRightJoin.java:81) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinProcessor.process(KTableKTableRightJoin.java:54) | |
| at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:82) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.kstream.internals.ForwardingCacheFlushListener.apply(ForwardingCacheFlushListener.java:40) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.putAndMaybeForward(CachingKeyValueStore.java:94) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.access$000(CachingKeyValueStore.java:33) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore$1.apply(CachingKeyValueStore.java:81) | |
| at org.apache.kafka.streams.state.internals.NamedCache.flush(NamedCache.java:117) | |
| at org.apache.kafka.streams.state.internals.NamedCache.evict(NamedCache.java:205) | |
| at org.apache.kafka.streams.state.internals.ThreadCache.maybeEvict(ThreadCache.java:199) | |
| at org.apache.kafka.streams.state.internals.ThreadCache.put(ThreadCache.java:121) | |
| 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$KTableKTableLeftJoinValueGetter.get(KTableKTableLeftJoin.java:118) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinValueGetter.get(KTableKTableLeftJoin.java:115) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinValueGetter.get(KTableKTableLeftJoin.java:115) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableLeftJoin$KTableKTableLeftJoinValueGetter.get(KTableKTableLeftJoin.java:115) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinProcessor.process(KTableKTableRightJoin.java:81) | |
| at org.apache.kafka.streams.kstream.internals.KTableKTableRightJoin$KTableKTableRightJoinProcessor.process(KTableKTableRightJoin.java:54) | |
| at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:82) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.kstream.internals.ForwardingCacheFlushListener.apply(ForwardingCacheFlushListener.java:40) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.putAndMaybeForward(CachingKeyValueStore.java:94) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.access$000(CachingKeyValueStore.java:33) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore$1.apply(CachingKeyValueStore.java:81) | |
| at org.apache.kafka.streams.state.internals.NamedCache.flush(NamedCache.java:117) | |
| at org.apache.kafka.streams.state.internals.NamedCache.evict(NamedCache.java:205) | |
| at org.apache.kafka.streams.state.internals.ThreadCache.maybeEvict(ThreadCache.java:199) | |
| at org.apache.kafka.streams.state.internals.ThreadCache.put(ThreadCache.java:121) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.put(CachingKeyValueStore.java:186) | |
| at org.apache.kafka.streams.state.internals.CachingKeyValueStore.put(CachingKeyValueStore.java:181) | |
| at org.apache.kafka.streams.kstream.internals.KTableAggregate$KTableAggregateProcessor.process(KTableAggregate.java:94) | |
| at org.apache.kafka.streams.kstream.internals.KTableAggregate$KTableAggregateProcessor.process(KTableAggregate.java:54) | |
| at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:82) | |
| at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:200) | |
| at org.apache.kafka.streams.processor.internals.SourceNode.process(SourceNode.java:66) | |
| at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:170) | |
| at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:575) | |
| at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:345) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment