Failed to lock the state directory due to an unexpected exception

21 views

Skip to first unread message

anand reddy akidi

unread,

Sep 28, 2017, 3:41:41 PM9/28/17

to Confluent Platform

Hi All,

what might the reason for this exception. Appreciate the immediate help.

2017-09-28 19:18:20.580 ERROR 11050 --- [-StreamThread-6] o.a.k.s.p.internals.StateDirectory : stream-thread [playerstats-beta-test3-70cfe4a4-134b-423c-b76f-a1c7243793ea-StreamThread-6] Failed to lock the state directory due to an unexpected exception

java.nio.file.DirectoryNotEmptyException: /var/kstreams-denormalizer/state/playerstats-beta-test3/6_58

at sun.nio.fs.UnixFileSystemProvider.implDelete(UnixFileSystemProvider.java:242) ~[na:1.8.0_131]

at sun.nio.fs.AbstractFileSystemProvider.delete(AbstractFileSystemProvider.java:103) ~[na:1.8.0_131]

at java.nio.file.Files.delete(Files.java:1126) ~[na:1.8.0_131]

at org.apache.kafka.common.utils.Utils$2.postVisitDirectory(Utils.java:597) ~[kafka-clients-0.11.0.0-cp1.jar!/:na]

at org.apache.kafka.common.utils.Utils$2.postVisitDirectory(Utils.java:580) ~[kafka-clients-0.11.0.0-cp1.jar!/:na]

at java.nio.file.Files.walkFileTree(Files.java:2688) ~[na:1.8.0_131]

at java.nio.file.Files.walkFileTree(Files.java:2742) ~[na:1.8.0_131]

at org.apache.kafka.common.utils.Utils.delete(Utils.java:580) ~[kafka-clients-0.11.0.0-cp1.jar!/:na]

at org.apache.kafka.streams.processor.internals.StateDirectory.cleanRemovedTasks(StateDirectory.java:223) ~[kafka-streams-0.11.0.0-cp1.jar!/:na]

at org.apache.kafka.streams.processor.internals.StreamThread.maybeClean(StreamThread.java:885) [kafka-streams-0.11.0.0-cp1.jar!/:na]

at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:561) [kafka-streams-0.11.0.0-cp1.jar!/:na]

at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:519) [kafka-streams-0.11.0.0-cp1.jar!/:na]

Regards

Anand.

Matthias J. Sax

unread,

Sep 28, 2017, 5:21:34 PM9/28/17

to confluent...@googlegroups.com

This might be fixed in 0.11.0.1 (cf.
https://issues.apache.org/jira/browse/KAFKA-5562)

Please try to upgrade and let us know if the issue is resolved in 0.11.0.1.

Thanks.

-Matthias

On 9/28/17 12:41 PM, anand reddy akidi wrote:
> Hi All,
>
>
> what might the reason for this exception. Appreciate the immediate help.
>
>
>
> 2017-09-28 19:18:20.580 ERROR 11050 --- [-StreamThread-6]
> o.a.k.s.p.internals.StateDirectory : stream-thread
> [playerstats-beta-test3-70cfe4a4-134b-423c-b76f-a1c7243793ea-StreamThread-6]
> Failed to lock the state directory due to an unexpected exception
>

> //

> --
> You received this message because you are subscribed to the Google
> Groups "Confluent Platform" group.
> To unsubscribe from this group and stop receiving emails from it, send
> an email to confluent-platf...@googlegroups.com
> <mailto:confluent-platf...@googlegroups.com>.
> To post to this group, send email to confluent...@googlegroups.com
> <mailto:confluent...@googlegroups.com>.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/confluent-platform/edaf69b5-99e8-4082-bf08-542f6da9de21%40googlegroups.com
> <https://groups.google.com/d/msgid/confluent-platform/edaf69b5-99e8-4082-bf08-542f6da9de21%40googlegroups.com?utm_medium=email&utm_source=footer>.
> For more options, visit https://groups.google.com/d/optout.