Support Questions

Find answers, ask questions, and share your expertise
Announcements
Celebrating as our community reaches 100,000 members! Thank you!

storm supervisor error

avatar
Super Collaborator

Hi,

I tried to run the Wordcount example storm-starter-0.0.1-storm-0.9.0.1.jar on storm in hdp2.5

The supervisor keeps going down and doesn't run giving below errro

java.io.FileNotFoundException: File '/datadrive/hadoop/storm/supervisor/stormdist/WordCount-2-1491988512/stormconf.ser' does not exist at org.apache.storm.shade.org.apache.commons.io.FileUtils.openInputStream(FileUtils.java:292)

I killed the topology still, same error persisits.

pls suggest.

Thanks,

Avijeet

1 ACCEPTED SOLUTION

avatar
Super Collaborator

I deleted this directory under /stormdist - and the error went away

View solution in original post

2 REPLIES 2

avatar
Super Collaborator

I deleted this directory under /stormdist - and the error went away

avatar
Contributor

For anyone that comes to this from google, as I did, you may also need to remove/backup the /hadoop/storm/supervisor/localstate directory.

It seems this keeps track of what the supervisor is currently running, so if the stormdist folder doesn't exist but there is a record in localstate, it will keep trying to access that file on startup.