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 >
signature.asc
Description: OpenPGP digital signature
