problem with number of iteration in nexttuple local mode

[Lidice Garcia <ta...@gmail.com>]

*Hi, *

*I have a problem running storm topology in local mode. *
*The nextuple function in my  spout always run **4059, or 15092,10690 ** times
and then died *

*I turn on the log and I watch next log,  at the end of the  mail attach
the code of my spout *
*Could you help me ??*


*There a time limit? limit of iterations? memory limit for the JVM?*


*I'm using 0.8.0 Storm Thank you for your help.*

[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:251
Accepted socket connection from /127.0.0.1:57742
[DEBUG] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:735
Session establishment request from client /127.0.0.1:57742 client's
lastZxid is 0x0
[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:777 Client
attempting to establish new session at /127.0.0.1:57742
[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:1580
Established session 0x1439dee3e7c000a with negotiated timeout 20000 for
client /127.0.0.1:57742
[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:1435
Closed socket connection for client /127.0.0.1:57742 which had sessionid
0x1439dee3e7c000a
[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:251
Accepted socket connection from /127.0.0.1:57745
[DEBUG] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:735
Session establishment request from client /127.0.0.1:57745 client's
lastZxid is 0x0
[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:777 Client
attempting to establish new session at /127.0.0.1:57745
[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:1580
Established session 0x1439dee3e7c000b with negotiated timeout 20000 for
client /127.0.0.1:57745
En el boltsource: amq-consumer:2, stream: default, id:
{7328779930586269645=-6664007187166544121},
[{"RH":59,"time":"01:31:31","idBase":"WSNBD_BS_SUR","CO":6,"O3":10,"date":"15/01/2014","TEMP":30,"nsensor":2516,"x":36}]values:[NodeMsm]:1class
java.lang.String
En el boltsource: amq-consumer:2, stream: default, id:
{-3759602190195762492=817255981805734090},
[{"RH":59,"time":"01:31:31","idBase":"WSNBD_BS_SUR","CO":6,"O3":10,"date":"15/01/2014","TEMP":30,"nsensor":8705,"x":36}]values:[NodeMsm]:1class
java.lang.String
[DEBUG] 16/01/14 20:01 itam.lgr.wsnbd.streamp.TopologyMainTest:36 Fin
[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:1435
Closed socket connection for client /127.0.0.1:57714 which had sessionid
0x1439dee3e7c0001
[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:1435
Closed socket connection for client /127.0.0.1:57723 which had sessionid
0x1439dee3e7c0003
[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:1435
Closed socket connection for client /127.0.0.1:57727 which had sessionid
0x1439dee3e7c0005
[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:1435
Closed socket connection for client /127.0.0.1:57745 which had sessionid
0x1439dee3e7c000b
[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:1435
Closed socket connection for client /127.0.0.1:57733 which had sessionid
0x1439dee3e7c0007
[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:1435
Closed socket connection for client /127.0.0.1:57739 which had sessionid
0x1439dee3e7c0009
[INFO ] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:278
NIOServerCnxn factory exited run method
[ERROR] 16/01/14 20:01 org.apache.zookeeper.server.NIOServerCnxn:81 Thread
Thread[main,5,main] died
java.io.IOException: Unable to delete file:
d:\USERPR~1\extds040\AppData\Local\Temp\6e594240-1100-495f-ada7-9d45c2660b08\version-2\log.1
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 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:413)
at backtype.storm.testing$kill_local_storm_cluster.invoke(testing.clj:163)
at backtype.storm.LocalCluster$_shutdown.invoke(LocalCluster.clj:21)
at backtype.storm.LocalCluster.shutdown(Unknown Source)
at itam.lgr.wsnbd.streamp.TopologyMainTest.main(TopologyMainTest.java:38)

*My code*

public class RandomSpout extends BaseRichSpout {

int i;
String val = "Some...";
private SpoutOutputCollector _collector;

public void open(Map conf, TopologyContext context,
SpoutOutputCollector collector) {
_collector = collector;
}

public void nextTuple() {
_collector.emit(new Values(val+(i++)), "NodeMsm");
}

public void declareOutputFields(OutputFieldsDeclarer declarer) {
declarer.declare(new Fields("NodeMsm"));

}

}