Uploaded image for project: 'AMQ Streams'
  1. AMQ Streams
  2. ENTMQST-5749

AMQ Streams ConcurrentModificationException in InMemoryTimeOrderedKeyValueBuffer

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Unresolved
    • Icon: Undefined Undefined
    • None
    • 2.3.0.GA
    • kafka-clients
    • None
    • False
    • None
    • False

      The following stack trace is repeatedly observed in a client:

      
org.apache.kafka.streams.errors.StreamsException: Exception caught in process 
...
stacktrace=java.util.ConcurrentModificationException
	at java.base/java.util.TreeMap$PrivateEntryIterator.remove(TreeMap.java:1507)
	at org.apache.kafka.streams.state.internals.InMemoryTimeOrderedKeyValueBuffer.evictWhile(InMemoryTimeOrderedKeyValueBuffer.java:423)
	at org.apache.kafka.streams.kstream.internals.suppress.KTableSuppressProcessorSupplier$KTableSuppressProcessor.enforceConstraints(KTableSuppressProcessorSupplier.java:178)
	at org.apache.kafka.streams.kstream.internals.suppress.KTableSuppressProcessorSupplier$KTableSuppressProcessor.process(KTableSuppressProcessorSupplier.java:165)
	at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:157)

        1. stack.txt
          11 kB

              Unassigned Unassigned
              rhn-support-shiggs Stephen Higgs
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated: