Yes- but not 100% repro. I seem to have several issues with start / rebalance
On Sun, Dec 11, 2016 at 2:16 PM, Matthias J. Sax <matth...@confluent.io> wrote: > Hi, > > this might be a recently discovered bug. Does it happen when you > stop/restart your application? > > > -Matthias > > On 12/10/16 1:42 PM, Jon Yeargers wrote: > > This came up a few times today: > > > > 2016-12-10 18:45:52,637 [StreamThread-1] ERROR > > o.a.k.s.p.internals.StreamThread - stream-thread [StreamThread-1] > Failed to > > create an active task %s: > > > > org.apache.kafka.streams.errors.ProcessorStateException: task [0_0] > Error > > while creating the state manager > > > > at > > org.apache.kafka.streams.processor.internals.AbstractTask.<init>( > AbstractTask.java:72) > > > > at > > org.apache.kafka.streams.processor.internals. > StreamTask.<init>(StreamTask.java:90) > > > > at > > org.apache.kafka.streams.processor.internals. > StreamThread.createStreamTask(StreamThread.java:633) > > > > at > > org.apache.kafka.streams.processor.internals. > StreamThread.addStreamTasks(StreamThread.java:660) > > > > at > > org.apache.kafka.streams.processor.internals.StreamThread.access$100( > StreamThread.java:69) > > > > at > > org.apache.kafka.streams.processor.internals.StreamThread$1. > onPartitionsAssigned(StreamThread.java:124) > > > > at > > org.apache.kafka.clients.consumer.internals.ConsumerCoordinator. > onJoinComplete(ConsumerCoordinator.java:228) > > > > at > > org.apache.kafka.clients.consumer.internals.AbstractCoordinator. > joinGroupIfNeeded(AbstractCoordinator.java:313) > > > > at > > org.apache.kafka.clients.consumer.internals.AbstractCoordinator. > ensureActiveGroup(AbstractCoordinator.java:277) > > > > at > > org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll( > ConsumerCoordinator.java:259) > > > > at > > org.apache.kafka.clients.consumer.KafkaConsumer. > pollOnce(KafkaConsumer.java:1013) > > > > at > > org.apache.kafka.clients.consumer.KafkaConsumer.poll( > KafkaConsumer.java:979) > > > > at > > org.apache.kafka.streams.processor.internals.StreamThread.runLoop( > StreamThread.java:407) > > > > at > > org.apache.kafka.streams.processor.internals. > StreamThread.run(StreamThread.java:242) > > > > Caused by: java.io.IOException: task [0_0] Failed to lock the state > > directory: /mnt/extra/space/MinuteAgg/0_0 > > > > at > > org.apache.kafka.streams.processor.internals. > ProcessorStateManager.<init>(ProcessorStateManager.java:101) > > > > at > > org.apache.kafka.streams.processor.internals.AbstractTask.<init>( > AbstractTask.java:69) > > > > ... 13 common frames omitted > > > >
