FAQ
Hi Sergei Zobnin ,

Did you resolve this issue? I met the same issue. Could you give me some
suggestion?

Thanks,
Liang Cui


在 2012年10月30日星期二UTC+8下午5时19分39秒,Sergei Zobnin写道:
Good day!

I am trying to kill a topology from the ui and have the following
exception in supervisor:

2012-10-30 11:26:44 supervisor [DEBUG] Synchronizing supervisor

2012-10-30 11:26:44 supervisor [DEBUG] Storm code map: {}

2012-10-30 11:26:44 supervisor [DEBUG] Downloaded storm ids:
#{"TransmitterTopology-1-1351581981"}
2012-10-30 11:26:44 supervisor [DEBUG] All assignment:

2012-10-30 11:26:44 supervisor [DEBUG] New assignment: {}

2012-10-30 11:26:44 supervisor [DEBUG] Writing new assignment {}

2012-10-30 11:26:44 supervisor [INFO] Removing code for storm id
TransmitterTopology-1-1351581981
2012-10-30 11:26:44 util [DEBUG] Rmr path
..\tmp\storm/supervisor/stormdist/TransmitterTopology-1-1351581981
2012-10-30 11:26:44 event [ERROR] Error when processing event

java.io.IOException: Unable to delete file:
..\tmp\storm\supervisor\stormdist\TransmitterTopology-1-1351581981\stormjar.jar
at org.apache.commons.io.FileUtils.forceDelete(FileUtils.java:1390)

at org.apache.commons.io.FileUtils.cleanDirectory(FileUtils.java:1044)

at org.apache.commons.io.FileUtils.deleteDirectory(FileUtils.java:977)

at org.apache.commons.io.FileUtils.forceDelete(FileUtils.java:1381)

at backtype.storm.util$rmr.invoke(util.clj:415)

at
backtype.storm.daemon.supervisor$mk_synchronize_supervisor$this__4702.invoke(supervisor.clj:317)
at backtype.storm.event$event_manager$fn__2485.invoke(event.clj:24)

at clojure.lang.AFn.run(AFn.java:24)

at java.lang.Thread.run(Thread.java:722)


..\tmp\storm\supervisor\stormdist\TransmitterTopology-1-1351581981\stormjar.jar
seems to be the only file, that is not deleted in the temporary directory,
this possibly happends because the worker process runs when the following
code is executed (supervisor.clj, 316):

(doseq [storm-id downloaded-storm-ids]
(when-not (assigned-storm-ids storm-id)
(log-message "Removing code for storm id "
storm-id)
(rmr (supervisor-stormdist-root conf storm-id))
))

I wonder if the worker process supposed to be killed by the time rmr
stormdist runs and if the worker process at least supposed to be killed
(like it is done in sync-processes)

Running storm-0.8.2-wip11.jar on a windows system (path separators are
already fixed and taskkill called in ensure-process-killed).

I would appreciate any ideas.

Thank you!

Search Discussions

Related Discussions

Discussion Navigation
viewthread | post
Discussion Overview
groupstorm-user @
postedDec 6, '12 at 9:47p
activeDec 6, '12 at 9:47p
posts1
users1
websitestorm-project.net
irc#storm-user

1 user in discussion

Liang cui: 1 post

People

Translate

site design / logo © 2022 Grokbase