Hi I am trying to use Storm Signals. I am running storm cluster on my local
machine. if I do not use storm-signals then my storm cluster is working
perfectly. But when i used storm-signals then i started getting errors in
my log files. My spout class, Topology class, pom.xml and error files are
attached. Please tell me what I am doing wrong.
Regards
Jamil Shehzad
package com.storm;
import backtype.storm.spout.SpoutOutputCollector;
import backtype.storm.task.TopologyContext;
import backtype.storm.topology.OutputFieldsDeclarer;
import backtype.storm.topology.base.BaseRichSpout;
import backtype.storm.tuple.Fields;
import backtype.storm.tuple.Values;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.util.Map;
import backtype.storm.contrib.signals.spout.BaseSignalSpout;
import org.apache.log4j.Logger;
@SuppressWarnings("serial")
public class NumberSpout extends BaseSignalSpout
{
public NumberSpout(String name) {
super(name);
// TODO Auto-generated constructor stub
}
/*public NumberSpout() {
//super(name);
// TODO Auto-generated constructor stub
}*/
//private SpoutOutputCollector collector;
private static final Logger LOGGER = Logger.getLogger(NumberSpout.class);
/* static String name="jamil";
*/
@SuppressWarnings("rawtypes")
@Override
public void open( Map conf, TopologyContext context, SpoutOutputCollector collector )
{ super.open(conf, context, collector);
//this.collector = collector;
LOGGER.info("In open method of spout");
}
@Override
public void nextTuple()
{
// Emit the next number
//String name=Person.getName();
/*if(name!=null){
LOGGER.info("Coming in spout tuble method");
collector.emit( new Values( new String( name ) ) );
name=null;
}*/
}
@Override
public void ack(Object id)
{
}
@Override
public void fail(Object id)
{
}
@Override
public void declareOutputFields(OutputFieldsDeclarer declarer)
{
declarer.declare( new Fields( "name" ) );
}
@Override
public void onSignal(byte[] data) {
// TODO Auto-generated method stub
/*name="adeel";
nextTuple();*/
LOGGER.info("Received signal: " + new String(data));
}
//@Override
/*protected void onSignal(byte[] arg0) {
// TODO Auto-generated method stub
System.out.println("On Signal"+arg0);
File file = new File("/home/jamil/file.txt");
try{
if (!file.exists()) {
file.createNewFile();
}
FileWriter fw = new FileWriter(file.getAbsoluteFile(), true);
BufferedWriter bw = new BufferedWriter(fw);
bw.write("In onSignal "+name + "\n");
bw.close();
}catch(Exception e){
e.printStackTrace();
}
}*/
}package com.storm;
import java.util.Map;
import java.util.Scanner;
import org.apache.log4j.Logger;
import org.apache.thrift7.TException;
import org.json.simple.JSONValue;
import backtype.storm.Config;
import backtype.storm.LocalCluster;
import backtype.storm.StormSubmitter;
import backtype.storm.generated.AlreadyAliveException;
import backtype.storm.generated.InvalidTopologyException;
import backtype.storm.generated.Nimbus.Client;
import backtype.storm.topology.TopologyBuilder;
import backtype.storm.utils.NimbusClient;
import backtype.storm.utils.Utils;
import backtype.storm.contrib.signals.spout.BaseSignalSpout;
import backtype.storm.contrib.signals.client.SignalClient;
import com.storm.NumberSpout;
public class PrimeNumberTopology
{
private static final Logger LOGGER = Logger.getLogger(PrimeNumberTopology.class);
public static void load(){
System.out.println("1");
TopologyBuilder builder = new TopologyBuilder();
System.out.println("2");
builder.setSpout( "signal-spout", new NumberSpout("test-signal-spout"));
System.out.println("3");
// builder.setBolt( "prime", new PrimeNumberBolt())
// .shuffleGrouping("spout");
System.out.println("4");
Config conf = new Config();
//conf.setNumWorkers(1);
//conf.setMaxTaskParallelism(1);
conf.put(Config.NIMBUS_HOST, "127.0.0.1");
conf.setDebug(true);
Map storm_conf = Utils.readStormConfig();
storm_conf.put("nimbus.host", "127.0.0.1");
Client client = NimbusClient.getConfiguredClient(storm_conf)
.getClient();
String inputJar = "/home/jamil/Downloads/storm-twitter-word-count-master/target/storm-test-1.0-SNAPSHOT.jar";
NimbusClient nimbus = new NimbusClient("127.0.0.1",6627);
// upload topology jar to Cluster using StormSubmitter
String uploadedJarLocation = StormSubmitter.submitJar(storm_conf,
inputJar);
try {
String jsonConf = JSONValue.toJSONString(storm_conf);
System.out.println("5");
nimbus.getClient().submitTopology("test1topology",
uploadedJarLocation, jsonConf, builder.createTopology());
System.out.println("6");
//Utils.sleep(10000);
} catch (AlreadyAliveException ae) {
ae.printStackTrace();
} catch (InvalidTopologyException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (TException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void main(String[] args)
{
load();
/*SignalClient sc = new SignalClient("localhost:2181", "test-signal-spout");
sc.start();
try {
sc.send("Hello Signal Spout!".getBytes());
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
sc.close();
}*/
/*for(int i=0;i<5;i++){
Scanner input=new Scanner(System.in);
System.out.println("Enter client number "+(i+1));
String name=input.next();
Person.setName(name);
}*/
//LOGGER.info("Coming in logger");
/* TopologyBuilder builder = new TopologyBuilder();
builder.setSpout( "spout", new NumberSpout(),1 );
builder.setBolt( "prime", new PrimeNumberBolt(),1 )
.shuffleGrouping("spout");
Config conf = new Config();
conf.put(Config.NIMBUS_HOST, "localhost");
conf.put(Config.NIMBUS_THRIFT_PORT,6627);
conf.put(Config.STORM_ZOOKEEPER_PORT,2181);
conf.put(Config.STORM_ZOOKEEPER_SERVERS,"localhost");
conf.setNumWorkers(2);
conf.setMaxSpoutPending(1);
System.setProperty("storm.jar", "/home/jamil/Downloads/storm-twitter-word-count-master/target/storm-test-1.0-SNAPSHOT.jar");
StormSubmitter submitter = new StormSubmitter();
try {
submitter.submitTopology( "newprimenumbertopology", conf, builder.createTopology() );
} catch (AlreadyAliveException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InvalidTopologyException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
Config conf = new Config();
LocalCluster cluster = new LocalCluster();
cluster.submitTopology("test", conf, builder.createTopology());
Utils.sleep(10000);
cluster.killTopology("test");
cluster.shutdown();
*/
/*TopologyBuilder builder = new TopologyBuilder();
builder.setSpout( "spout", new NumberSpout() );
builder.setBolt( "prime", new PrimeNumberBolt() )
.shuffleGrouping("spout");
Config conf = new Config();
conf.setNumWorkers(20);
conf.setMaxSpoutPending(5000);
try {
StormSubmitter.submitTopology( "topology", conf, builder.createTopology() );
} catch (AlreadyAliveException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InvalidTopologyException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}*/
}
}<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";>
<modelVersion>4.0.0</modelVersion>
<groupId>com.storm</groupId>
<artifactId>storm-test</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>jar</packaging>
<name>storm-test</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>2.0.2</version>
<configuration>
<source>1.6</source>
<target>1.6</target>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-jar-plugin</artifactId>
<configuration>
<archive>
<manifest>
<addClasspath>true</addClasspath>
<classpathPrefix>lib/</classpathPrefix>
<mainClass>com.storm.PrimeNumberTopology</mainClass>
</manifest>
</archive>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-dependency-plugin</artifactId>
</plugin>
</plugins>
</build>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.github.ptgoetz</groupId>
<artifactId>storm-signals</artifactId>
<version>0.2.0</version>
</dependency>
<dependency>
<groupId>storm</groupId>
<artifactId>storm-lib</artifactId>
<version>0.8.1</version>
<!-- keep storm out of the jar-with-dependencies <scope>provided</scope> -->
</dependency>
</dependencies>
<repositories>
<repository>
<id>github-releases</id>
<url>http://oss.sonatype.org/content/repositories/github-releases/</url>
</repository>
<repository>
<id>clojars.org</id>
<url>http://clojars.org/repo</url>
</repository>
</repositories>
</project>
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:zookeeper.version=3.3.3-1073969, built on 02/23/2011 22:27 GMT
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:host.name=localhost
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:java.version=1.6.0_32
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:java.vendor=Sun Microsystems Inc.
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:java.home=/usr/lib/jvm/java-6-openjdk-amd64/jre
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:java.class.path=/home/jamil/storm/lib/guava-13.0.jar:/home/jamil/storm/lib/jline-2.11.jar:/home/jamil/storm/lib/asm-4.0.jar:/home/jamil/storm/lib/curator-client-1.0.1.jar:/home/jamil/storm/lib/ring-jetty-adapter-0.3.11.jar:/home/jamil/storm/lib/clj-time-0.4.1.jar:/home/jamil/storm/lib/junit-3.8.1.jar:/home/jamil/storm/lib/tools.cli-0.2.2.jar:/home/jamil/storm/lib/slf4j-api-1.6.5.jar:/home/jamil/storm/lib/joda-time-2.0.jar:/home/jamil/storm/lib/json-simple-1.1.jar:/home/jamil/storm/lib/jgrapht-core-0.9.0.jar:/home/jamil/storm/lib/commons-exec-1.1.jar:/home/jamil/storm/lib/jetty-util-6.1.26.jar:/home/jamil/storm/lib/servlet-api-2.5-20081211.jar:/home/jamil/storm/lib/commons-codec-1.4.jar:/home/jamil/storm/lib/storm-core-0.9.1-incubating.jar:/home/jamil/storm/lib/ring-core-1.1.5.jar:/home/jamil/storm/lib/reflectasm-1.07-shaded.jar:/home/jamil/storm/lib/httpclient-4.1.1.jar:/home/jamil/storm/lib/snakeyaml-1.11.jar:/home/jamil/storm/lib/logback-core-1.0.6.jar:/home/jamil/storm/lib/httpcore-4.1.jar:/home/jamil/storm/lib/commons-io-1.4.jar:/home/jamil/storm/lib/meat-locker-0.3.1.jar:/home/jamil/storm/lib/core.incubator-0.1.0.jar:/home/jamil/storm/lib/clout-1.0.1.jar:/home/jamil/storm/lib/commons-lang-2.5.jar:/home/jamil/storm/lib/tools.logging-0.2.3.jar:/home/jamil/storm/lib/curator-framework-1.0.1.jar:/home/jamil/storm/lib/netty-3.6.3.Final.jar:/home/jamil/storm/lib/tools.macro-0.1.0.jar:/home/jamil/storm/lib/commons-logging-1.1.1.jar:/home/jamil/storm/lib/hiccup-0.3.6.jar:/home/jamil/storm/lib/carbonite-1.3.2.jar:/home/jamil/storm/lib/clj-stacktrace-0.2.4.jar:/home/jamil/storm/lib/commons-fileupload-1.2.1.jar:/home/jamil/storm/lib/ring-devel-0.3.11.jar:/home/jamil/storm/lib/objenesis-1.2.jar:/home/jamil/storm/lib/math.numeric-tower-0.0.1.jar:/home/jamil/storm/lib/kryo-2.17.jar:/home/jamil/storm/lib/compojure-1.1.3.jar:/home/jamil/storm/lib/minlog-1.2.jar:/home/jamil/storm/lib/log4j-over-slf4j-1.6.6.jar:/home/jamil/storm/lib/clojure-1.4.0.jar:/home/jamil/storm/lib/disruptor-2.10.1.jar:/home/jamil/storm/lib/ring-servlet-0.3.11.jar:/home/jamil/storm/lib/logback-classic-1.0.6.jar:/home/jamil/storm/lib/zookeeper-3.3.3.jar:/home/jamil/storm/lib/jetty-6.1.26.jar:/home/jamil/storm/lib/servlet-api-2.5.jar:/home/jamil/storm/conf:/home/jamil/storm/data/supervisor/stormdist/test1topology-5-1414334708/stormjar.jar
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:java.library.path=/usr/lib/jvm/jdk1.7.0_67
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:java.io.tmpdir=/tmp
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:java.compiler=<NA>
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:os.name=Linux
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:os.arch=amd64
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:os.version=3.13.0-36-generic
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:user.name=root
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:user.home=/root
2014-10-26 19:45:15 o.a.z.ZooKeeper [INFO] Client environment:user.dir=/home/jamil/storm/bin
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:zookeeper.version=3.3.3-1073969, built on 02/23/2011 22:27 GMT
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:host.name=localhost
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.version=1.6.0_32
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.vendor=Sun Microsystems Inc.
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.home=/usr/lib/jvm/java-6-openjdk-amd64/jre
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.class.path=/home/jamil/storm/lib/guava-13.0.jar:/home/jamil/storm/lib/jline-2.11.jar:/home/jamil/storm/lib/asm-4.0.jar:/home/jamil/storm/lib/curator-client-1.0.1.jar:/home/jamil/storm/lib/ring-jetty-adapter-0.3.11.jar:/home/jamil/storm/lib/clj-time-0.4.1.jar:/home/jamil/storm/lib/junit-3.8.1.jar:/home/jamil/storm/lib/tools.cli-0.2.2.jar:/home/jamil/storm/lib/slf4j-api-1.6.5.jar:/home/jamil/storm/lib/joda-time-2.0.jar:/home/jamil/storm/lib/json-simple-1.1.jar:/home/jamil/storm/lib/jgrapht-core-0.9.0.jar:/home/jamil/storm/lib/commons-exec-1.1.jar:/home/jamil/storm/lib/jetty-util-6.1.26.jar:/home/jamil/storm/lib/servlet-api-2.5-20081211.jar:/home/jamil/storm/lib/commons-codec-1.4.jar:/home/jamil/storm/lib/storm-core-0.9.1-incubating.jar:/home/jamil/storm/lib/ring-core-1.1.5.jar:/home/jamil/storm/lib/reflectasm-1.07-shaded.jar:/home/jamil/storm/lib/httpclient-4.1.1.jar:/home/jamil/storm/lib/snakeyaml-1.11.jar:/home/jamil/storm/lib/logback-core-1.0.6.jar:/home/jamil/storm/lib/httpcore-4.1.jar:/home/jamil/storm/lib/commons-io-1.4.jar:/home/jamil/storm/lib/meat-locker-0.3.1.jar:/home/jamil/storm/lib/core.incubator-0.1.0.jar:/home/jamil/storm/lib/clout-1.0.1.jar:/home/jamil/storm/lib/commons-lang-2.5.jar:/home/jamil/storm/lib/tools.logging-0.2.3.jar:/home/jamil/storm/lib/curator-framework-1.0.1.jar:/home/jamil/storm/lib/netty-3.6.3.Final.jar:/home/jamil/storm/lib/tools.macro-0.1.0.jar:/home/jamil/storm/lib/commons-logging-1.1.1.jar:/home/jamil/storm/lib/hiccup-0.3.6.jar:/home/jamil/storm/lib/carbonite-1.3.2.jar:/home/jamil/storm/lib/clj-stacktrace-0.2.4.jar:/home/jamil/storm/lib/commons-fileupload-1.2.1.jar:/home/jamil/storm/lib/ring-devel-0.3.11.jar:/home/jamil/storm/lib/objenesis-1.2.jar:/home/jamil/storm/lib/math.numeric-tower-0.0.1.jar:/home/jamil/storm/lib/kryo-2.17.jar:/home/jamil/storm/lib/compojure-1.1.3.jar:/home/jamil/storm/lib/minlog-1.2.jar:/home/jamil/storm/lib/log4j-over-slf4j-1.6.6.jar:/home/jamil/storm/lib/clojure-1.4.0.jar:/home/jamil/storm/lib/disruptor-2.10.1.jar:/home/jamil/storm/lib/ring-servlet-0.3.11.jar:/home/jamil/storm/lib/logback-classic-1.0.6.jar:/home/jamil/storm/lib/zookeeper-3.3.3.jar:/home/jamil/storm/lib/jetty-6.1.26.jar:/home/jamil/storm/lib/servlet-api-2.5.jar:/home/jamil/storm/conf:/home/jamil/storm/data/supervisor/stormdist/test1topology-5-1414334708/stormjar.jar
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.library.path=/usr/lib/jvm/jdk1.7.0_67
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.io.tmpdir=/tmp
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.compiler=<NA>
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:os.name=Linux
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:os.arch=amd64
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:os.version=3.13.0-36-generic
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:user.name=root
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:user.home=/root
2014-10-26 19:45:15 o.a.z.s.ZooKeeperServer [INFO] Server environment:user.dir=/home/jamil/storm/bin
2014-10-26 19:45:18 b.s.d.worker [INFO] Launching worker for test1topology-5-1414334708 on 7636a8b8-17e4-4cb2-99a1-0435215a8fe9:6703 with id a7a38582-dbd0-47c6-bc57-f7ba5eccc170 and conf {"dev.zookeeper.path" "/tmp/dev-storm-zookeeper", "topology.tick.tuple.freq.secs" nil, "topology.builtin.metrics.bucket.size.secs" 60, "topology.fall.back.on.java.serialization" true, "topology.max.error.report.per.interval" 5, "zmq.linger.millis" 5000, "topology.skip.missing.kryo.registrations" false, "storm.messaging.netty.client_worker_threads" 1, "ui.childopts" "-Xmx768m", "storm.zookeeper.session.timeout" 20000, "nimbus.reassign" true, "topology.trident.batch.emit.interval.millis" 500, "nimbus.monitor.freq.secs" 10, "logviewer.childopts" "-Xmx128m", "java.library.path" "/usr/lib/jvm/jdk1.7.0_67", "topology.executor.send.buffer.size" 1024, "storm.local.dir" "/home/jamil/storm/data", "storm.messaging.netty.buffer_size" 5242880, "supervisor.worker.start.timeout.secs" 120, "topology.enable.message.timeouts" true, "nimbus.cleanup.inbox.freq.secs" 600, "nimbus.inbox.jar.expiration.secs" 3600, "drpc.worker.threads" 64, "topology.worker.shared.thread.pool.size" 4, "nimbus.host" "localhost", "storm.messaging.netty.min_wait_ms" 100, "storm.zookeeper.port" 2181, "transactional.zookeeper.port" nil, "topology.executor.receive.buffer.size" 1024, "transactional.zookeeper.servers" nil, "storm.zookeeper.root" "/storm", "storm.zookeeper.retry.intervalceiling.millis" 30000, "supervisor.enable" true, "storm.messaging.netty.server_worker_threads" 1, "storm.zookeeper.servers" ["localhost"], "transactional.zookeeper.root" "/transactional", "topology.acker.executors" nil, "topology.transfer.buffer.size" 1024, "topology.worker.childopts" nil, "drpc.queue.size" 128, "worker.childopts" "-Xmx768m", "supervisor.heartbeat.frequency.secs" 5, "topology.error.throttle.interval.secs" 10, "zmq.hwm" 0, "drpc.port" 3772, "supervisor.monitor.frequency.secs" 3, "drpc.childopts" "-Xmx768m", "topology.receiver.buffer.size" 8, "task.heartbeat.frequency.secs" 3, "topology.tasks" nil, "storm.messaging.netty.max_retries" 30, "topology.spout.wait.strategy" "backtype.storm.spout.SleepSpoutWaitStrategy", "nimbus.thrift.max_buffer_size" 1048576, "topology.max.spout.pending" nil, "storm.zookeeper.retry.interval" 1000, "topology.sleep.spout.wait.strategy.time.ms" 1, "nimbus.topology.validator" "backtype.storm.nimbus.DefaultTopologyValidator", "supervisor.slots.ports" [6700 6701 6702 6703], "topology.debug" false, "nimbus.task.launch.secs" 120, "nimbus.supervisor.timeout.secs" 60, "topology.message.timeout.secs" 30, "task.refresh.poll.secs" 10, "topology.workers" 1, "supervisor.childopts" "-Xmx256m", "nimbus.thrift.port" 6627, "topology.stats.sample.rate" 0.05, "worker.heartbeat.frequency.secs" 1, "topology.tuple.serializer" "backtype.storm.serialization.types.ListDelegateSerializer", "topology.disruptor.wait.strategy" "com.lmax.disruptor.BlockingWaitStrategy", "nimbus.task.timeout.secs" 30, "storm.zookeeper.connection.timeout" 15000, "topology.kryo.factory" "backtype.storm.serialization.DefaultKryoFactory", "drpc.invocations.port" 3773, "logviewer.port" 8000, "zmq.threads" 1, "storm.zookeeper.retry.times" 5, "storm.thrift.transport" "backtype.storm.security.auth.SimpleTransportPlugin", "topology.state.synchronization.timeout.secs" 60, "supervisor.worker.timeout.secs" 30, "nimbus.file.copy.expiration.secs" 600, "storm.messaging.transport" "backtype.storm.messaging.netty.Context", "logviewer.appender.name" "A1", "storm.messaging.netty.max_wait_ms" 1000, "drpc.request.timeout.secs" 600, "storm.local.mode.zmq" false, "ui.port" 8772, "nimbus.childopts" "-Xmx1024m", "storm.cluster.mode" "distributed", "topology.optimize" true, "topology.max.task.parallelism" nil}
2014-10-26 19:45:18 c.n.c.f.i.CuratorFrameworkImpl [INFO] Starting
2014-10-26 19:45:18 o.a.z.ZooKeeper [INFO] Initiating client connection, connectString=localhost:2181 sessionTimeout=20000 watcher=com.netflix.curator.ConnectionState@72039bf7
2014-10-26 19:45:18 o.a.z.ClientCnxn [INFO] Opening socket connection to server localhost/127.0.0.1:2181
2014-10-26 19:45:18 o.a.z.ClientCnxn [INFO] Socket connection established to localhost/127.0.0.1:2181, initiating session
2014-10-26 19:45:18 o.a.z.ClientCnxn [INFO] Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x1494c96c985005c, negotiated timeout = 20000
2014-10-26 19:45:18 b.s.zookeeper [INFO] Zookeeper state update: :connected:none
2014-10-26 19:45:18 o.a.z.ZooKeeper [INFO] Session: 0x1494c96c985005c closed
2014-10-26 19:45:18 o.a.z.ClientCnxn [INFO] EventThread shut down
2014-10-26 19:45:18 c.n.c.f.i.CuratorFrameworkImpl [INFO] Starting
2014-10-26 19:45:18 o.a.z.ZooKeeper [INFO] Initiating client connection, connectString=localhost:2181/storm sessionTimeout=20000 watcher=com.netflix.curator.ConnectionState@12f212e6
2014-10-26 19:45:18 o.a.z.ClientCnxn [INFO] Opening socket connection to server localhost/127.0.0.1:2181
2014-10-26 19:45:18 o.a.z.ClientCnxn [INFO] Socket connection established to localhost/127.0.0.1:2181, initiating session
2014-10-26 19:45:18 o.a.z.ClientCnxn [INFO] Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x1494c96c985005d, negotiated timeout = 20000
2014-10-26 19:45:18 b.s.m.TransportFactory [INFO] Storm peer transport plugin:backtype.storm.messaging.netty.Context
2014-10-26 19:45:19 b.s.d.executor [INFO] Loading executor signal-spout:[2 2]
2014-10-26 19:45:19 b.s.d.worker [ERROR] Error on initialization of server mk-worker
java.lang.NoClassDefFoundError: backtype/storm/contrib/signals/spout/BaseSignalSpout
at java.lang.ClassLoader.defineClass1(Native Method) ~[na:1.6.0_32]
at java.lang.ClassLoader.defineClass(ClassLoader.java:643) ~[na:1.6.0_32]
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) ~[na:1.6.0_32]
at java.net.URLClassLoader.defineClass(URLClassLoader.java:277) ~[na:1.6.0_32]
at java.net.URLClassLoader.access$000(URLClassLoader.java:73) ~[na:1.6.0_32]
at java.net.URLClassLoader$1.run(URLClassLoader.java:212) ~[na:1.6.0_32]
at java.security.AccessController.doPrivileged(Native Method) ~[na:1.6.0_32]
at java.net.URLClassLoader.findClass(URLClassLoader.java:205) ~[na:1.6.0_32]
at java.lang.ClassLoader.loadClass(ClassLoader.java:323) ~[na:1.6.0_32]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:294) ~[na:1.6.0_32]
at java.lang.ClassLoader.loadClass(ClassLoader.java:268) ~[na:1.6.0_32]
at java.lang.Class.forName0(Native Method) ~[na:1.6.0_32]
at java.lang.Class.forName(Class.java:270) ~[na:1.6.0_32]
at java.io.ObjectInputStream.resolveClass(ObjectInputStream.java:624) ~[na:1.6.0_32]
at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1611) ~[na:1.6.0_32]
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1516) ~[na:1.6.0_32]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1770) ~[na:1.6.0_32]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1349) ~[na:1.6.0_32]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:369) ~[na:1.6.0_32]
at backtype.storm.utils.Utils.deserialize(Utils.java:82) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.utils.Utils.getSetComponentObject(Utils.java:218) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.daemon.task$get_task_object.invoke(task.clj:73) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.daemon.task$mk_task_data$fn__3402.invoke(task.clj:180) ~[na:na]
at backtype.storm.util$assoc_apply_self.invoke(util.clj:792) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.daemon.task$mk_task_data.invoke(task.clj:173) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.daemon.task$mk_task.invoke(task.clj:184) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.daemon.executor$mk_executor$fn__3785.invoke(executor.clj:320) ~[na:na]
at clojure.core$map$fn__4087.invoke(core.clj:2432) ~[clojure-1.4.0.jar:na]
at clojure.lang.LazySeq.sval(LazySeq.java:42) ~[clojure-1.4.0.jar:na]
at clojure.lang.LazySeq.seq(LazySeq.java:60) ~[clojure-1.4.0.jar:na]
at clojure.lang.RT.seq(RT.java:473) ~[clojure-1.4.0.jar:na]
at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.4.0.jar:na]
at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) ~[clojure-1.4.0.jar:na]
at clojure.core.protocols$fn__5875.invoke(protocols.clj:54) ~[clojure-1.4.0.jar:na]
at clojure.core.protocols$fn__5828$G__5823__5841.invoke(protocols.clj:13) ~[clojure-1.4.0.jar:na]
at clojure.core$reduce.invoke(core.clj:6030) ~[clojure-1.4.0.jar:na]
at clojure.core$into.invoke(core.clj:6077) ~[clojure-1.4.0.jar:na]
at backtype.storm.daemon.executor$mk_executor.invoke(executor.clj:320) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.daemon.worker$eval4413$exec_fn__1102__auto____4414$iter__4419__4423$fn__4424.invoke(worker.clj:375) ~[na:na]
at clojure.lang.LazySeq.sval(LazySeq.java:42) ~[clojure-1.4.0.jar:na]
at clojure.lang.LazySeq.seq(LazySeq.java:60) ~[clojure-1.4.0.jar:na]
at clojure.lang.RT.seq(RT.java:473) ~[clojure-1.4.0.jar:na]
at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.4.0.jar:na]
at clojure.core$dorun.invoke(core.clj:2725) ~[clojure-1.4.0.jar:na]
at clojure.core$doall.invoke(core.clj:2741) ~[clojure-1.4.0.jar:na]
at backtype.storm.daemon.worker$eval4413$exec_fn__1102__auto____4414.invoke(worker.clj:375) ~[na:na]
at clojure.lang.AFn.applyToHelper(AFn.java:185) ~[clojure-1.4.0.jar:na]
at clojure.lang.AFn.applyTo(AFn.java:151) ~[clojure-1.4.0.jar:na]
at clojure.core$apply.invoke(core.clj:601) ~[clojure-1.4.0.jar:na]
at backtype.storm.daemon.worker$eval4413$mk_worker__4469.doInvoke(worker.clj:344) ~[na:na]
at clojure.lang.RestFn.invoke(RestFn.java:512) ~[clojure-1.4.0.jar:na]
at backtype.storm.daemon.worker$_main.invoke(worker.clj:454) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at clojure.lang.AFn.applyToHelper(AFn.java:172) ~[clojure-1.4.0.jar:na]
at clojure.lang.AFn.applyTo(AFn.java:151) ~[clojure-1.4.0.jar:na]
at backtype.storm.daemon.worker.main(Unknown Source) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
Caused by: java.lang.ClassNotFoundException: backtype.storm.contrib.signals.spout.BaseSignalSpout
at java.net.URLClassLoader$1.run(URLClassLoader.java:217) ~[na:1.6.0_32]
at java.security.AccessController.doPrivileged(Native Method) ~[na:1.6.0_32]
at java.net.URLClassLoader.findClass(URLClassLoader.java:205) ~[na:1.6.0_32]
at java.lang.ClassLoader.loadClass(ClassLoader.java:323) ~[na:1.6.0_32]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:294) ~[na:1.6.0_32]
at java.lang.ClassLoader.loadClass(ClassLoader.java:268) ~[na:1.6.0_32]
... 55 common frames omitted
2014-10-26 19:45:19 b.s.util [INFO] Halting process: ("Error on initialization")
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:zookeeper.version=3.3.3-1073969, built on 02/23/2011 22:27 GMT
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:host.name=localhost
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:java.version=1.6.0_32
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:java.vendor=Sun Microsystems Inc.
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:java.home=/usr/lib/jvm/java-6-openjdk-amd64/jre
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:java.class.path=/home/jamil/storm/lib/guava-13.0.jar:/home/jamil/storm/lib/jline-2.11.jar:/home/jamil/storm/lib/asm-4.0.jar:/home/jamil/storm/lib/curator-client-1.0.1.jar:/home/jamil/storm/lib/ring-jetty-adapter-0.3.11.jar:/home/jamil/storm/lib/clj-time-0.4.1.jar:/home/jamil/storm/lib/junit-3.8.1.jar:/home/jamil/storm/lib/tools.cli-0.2.2.jar:/home/jamil/storm/lib/slf4j-api-1.6.5.jar:/home/jamil/storm/lib/joda-time-2.0.jar:/home/jamil/storm/lib/json-simple-1.1.jar:/home/jamil/storm/lib/jgrapht-core-0.9.0.jar:/home/jamil/storm/lib/commons-exec-1.1.jar:/home/jamil/storm/lib/jetty-util-6.1.26.jar:/home/jamil/storm/lib/servlet-api-2.5-20081211.jar:/home/jamil/storm/lib/commons-codec-1.4.jar:/home/jamil/storm/lib/storm-core-0.9.1-incubating.jar:/home/jamil/storm/lib/ring-core-1.1.5.jar:/home/jamil/storm/lib/reflectasm-1.07-shaded.jar:/home/jamil/storm/lib/httpclient-4.1.1.jar:/home/jamil/storm/lib/snakeyaml-1.11.jar:/home/jamil/storm/lib/logback-core-1.0.6.jar:/home/jamil/storm/lib/httpcore-4.1.jar:/home/jamil/storm/lib/commons-io-1.4.jar:/home/jamil/storm/lib/meat-locker-0.3.1.jar:/home/jamil/storm/lib/core.incubator-0.1.0.jar:/home/jamil/storm/lib/clout-1.0.1.jar:/home/jamil/storm/lib/commons-lang-2.5.jar:/home/jamil/storm/lib/tools.logging-0.2.3.jar:/home/jamil/storm/lib/curator-framework-1.0.1.jar:/home/jamil/storm/lib/netty-3.6.3.Final.jar:/home/jamil/storm/lib/tools.macro-0.1.0.jar:/home/jamil/storm/lib/commons-logging-1.1.1.jar:/home/jamil/storm/lib/hiccup-0.3.6.jar:/home/jamil/storm/lib/carbonite-1.3.2.jar:/home/jamil/storm/lib/clj-stacktrace-0.2.4.jar:/home/jamil/storm/lib/commons-fileupload-1.2.1.jar:/home/jamil/storm/lib/ring-devel-0.3.11.jar:/home/jamil/storm/lib/objenesis-1.2.jar:/home/jamil/storm/lib/math.numeric-tower-0.0.1.jar:/home/jamil/storm/lib/kryo-2.17.jar:/home/jamil/storm/lib/compojure-1.1.3.jar:/home/jamil/storm/lib/minlog-1.2.jar:/home/jamil/storm/lib/log4j-over-slf4j-1.6.6.jar:/home/jamil/storm/lib/clojure-1.4.0.jar:/home/jamil/storm/lib/disruptor-2.10.1.jar:/home/jamil/storm/lib/ring-servlet-0.3.11.jar:/home/jamil/storm/lib/logback-classic-1.0.6.jar:/home/jamil/storm/lib/zookeeper-3.3.3.jar:/home/jamil/storm/lib/jetty-6.1.26.jar:/home/jamil/storm/lib/servlet-api-2.5.jar:/home/jamil/storm/conf:/home/jamil/storm/data/supervisor/stormdist/test1topology-5-1414334708/stormjar.jar
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:java.library.path=/usr/lib/jvm/jdk1.7.0_67
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:java.io.tmpdir=/tmp
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:java.compiler=<NA>
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:os.name=Linux
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:os.arch=amd64
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:os.version=3.13.0-36-generic
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:user.name=root
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:user.home=/root
2014-10-26 19:45:54 o.a.z.ZooKeeper [INFO] Client environment:user.dir=/home/jamil/storm/bin
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:zookeeper.version=3.3.3-1073969, built on 02/23/2011 22:27 GMT
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:host.name=localhost
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.version=1.6.0_32
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.vendor=Sun Microsystems Inc.
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.home=/usr/lib/jvm/java-6-openjdk-amd64/jre
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.class.path=/home/jamil/storm/lib/guava-13.0.jar:/home/jamil/storm/lib/jline-2.11.jar:/home/jamil/storm/lib/asm-4.0.jar:/home/jamil/storm/lib/curator-client-1.0.1.jar:/home/jamil/storm/lib/ring-jetty-adapter-0.3.11.jar:/home/jamil/storm/lib/clj-time-0.4.1.jar:/home/jamil/storm/lib/junit-3.8.1.jar:/home/jamil/storm/lib/tools.cli-0.2.2.jar:/home/jamil/storm/lib/slf4j-api-1.6.5.jar:/home/jamil/storm/lib/joda-time-2.0.jar:/home/jamil/storm/lib/json-simple-1.1.jar:/home/jamil/storm/lib/jgrapht-core-0.9.0.jar:/home/jamil/storm/lib/commons-exec-1.1.jar:/home/jamil/storm/lib/jetty-util-6.1.26.jar:/home/jamil/storm/lib/servlet-api-2.5-20081211.jar:/home/jamil/storm/lib/commons-codec-1.4.jar:/home/jamil/storm/lib/storm-core-0.9.1-incubating.jar:/home/jamil/storm/lib/ring-core-1.1.5.jar:/home/jamil/storm/lib/reflectasm-1.07-shaded.jar:/home/jamil/storm/lib/httpclient-4.1.1.jar:/home/jamil/storm/lib/snakeyaml-1.11.jar:/home/jamil/storm/lib/logback-core-1.0.6.jar:/home/jamil/storm/lib/httpcore-4.1.jar:/home/jamil/storm/lib/commons-io-1.4.jar:/home/jamil/storm/lib/meat-locker-0.3.1.jar:/home/jamil/storm/lib/core.incubator-0.1.0.jar:/home/jamil/storm/lib/clout-1.0.1.jar:/home/jamil/storm/lib/commons-lang-2.5.jar:/home/jamil/storm/lib/tools.logging-0.2.3.jar:/home/jamil/storm/lib/curator-framework-1.0.1.jar:/home/jamil/storm/lib/netty-3.6.3.Final.jar:/home/jamil/storm/lib/tools.macro-0.1.0.jar:/home/jamil/storm/lib/commons-logging-1.1.1.jar:/home/jamil/storm/lib/hiccup-0.3.6.jar:/home/jamil/storm/lib/carbonite-1.3.2.jar:/home/jamil/storm/lib/clj-stacktrace-0.2.4.jar:/home/jamil/storm/lib/commons-fileupload-1.2.1.jar:/home/jamil/storm/lib/ring-devel-0.3.11.jar:/home/jamil/storm/lib/objenesis-1.2.jar:/home/jamil/storm/lib/math.numeric-tower-0.0.1.jar:/home/jamil/storm/lib/kryo-2.17.jar:/home/jamil/storm/lib/compojure-1.1.3.jar:/home/jamil/storm/lib/minlog-1.2.jar:/home/jamil/storm/lib/log4j-over-slf4j-1.6.6.jar:/home/jamil/storm/lib/clojure-1.4.0.jar:/home/jamil/storm/lib/disruptor-2.10.1.jar:/home/jamil/storm/lib/ring-servlet-0.3.11.jar:/home/jamil/storm/lib/logback-classic-1.0.6.jar:/home/jamil/storm/lib/zookeeper-3.3.3.jar:/home/jamil/storm/lib/jetty-6.1.26.jar:/home/jamil/storm/lib/servlet-api-2.5.jar:/home/jamil/storm/conf:/home/jamil/storm/data/supervisor/stormdist/test1topology-5-1414334708/stormjar.jar
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.library.path=/usr/lib/jvm/jdk1.7.0_67
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.io.tmpdir=/tmp
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:java.compiler=<NA>
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:os.name=Linux
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:os.arch=amd64
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:os.version=3.13.0-36-generic
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:user.name=root
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:user.home=/root
2014-10-26 19:45:54 o.a.z.s.ZooKeeperServer [INFO] Server environment:user.dir=/home/jamil/storm/bin
2014-10-26 19:45:57 b.s.d.worker [INFO] Launching worker for test1topology-5-1414334708 on 7636a8b8-17e4-4cb2-99a1-0435215a8fe9:6703 with id ef693f6a-cc85-495b-ba7e-32ac8c70a296 and conf {"dev.zookeeper.path" "/tmp/dev-storm-zookeeper", "topology.tick.tuple.freq.secs" nil, "topology.builtin.metrics.bucket.size.secs" 60, "topology.fall.back.on.java.serialization" true, "topology.max.error.report.per.interval" 5, "zmq.linger.millis" 5000, "topology.skip.missing.kryo.registrations" false, "storm.messaging.netty.client_worker_threads" 1, "ui.childopts" "-Xmx768m", "storm.zookeeper.session.timeout" 20000, "nimbus.reassign" true, "topology.trident.batch.emit.interval.millis" 500, "nimbus.monitor.freq.secs" 10, "logviewer.childopts" "-Xmx128m", "java.library.path" "/usr/lib/jvm/jdk1.7.0_67", "topology.executor.send.buffer.size" 1024, "storm.local.dir" "/home/jamil/storm/data", "storm.messaging.netty.buffer_size" 5242880, "supervisor.worker.start.timeout.secs" 120, "topology.enable.message.timeouts" true, "nimbus.cleanup.inbox.freq.secs" 600, "nimbus.inbox.jar.expiration.secs" 3600, "drpc.worker.threads" 64, "topology.worker.shared.thread.pool.size" 4, "nimbus.host" "localhost", "storm.messaging.netty.min_wait_ms" 100, "storm.zookeeper.port" 2181, "transactional.zookeeper.port" nil, "topology.executor.receive.buffer.size" 1024, "transactional.zookeeper.servers" nil, "storm.zookeeper.root" "/storm", "storm.zookeeper.retry.intervalceiling.millis" 30000, "supervisor.enable" true, "storm.messaging.netty.server_worker_threads" 1, "storm.zookeeper.servers" ["localhost"], "transactional.zookeeper.root" "/transactional", "topology.acker.executors" nil, "topology.transfer.buffer.size" 1024, "topology.worker.childopts" nil, "drpc.queue.size" 128, "worker.childopts" "-Xmx768m", "supervisor.heartbeat.frequency.secs" 5, "topology.error.throttle.interval.secs" 10, "zmq.hwm" 0, "drpc.port" 3772, "supervisor.monitor.frequency.secs" 3, "drpc.childopts" "-Xmx768m", "topology.receiver.buffer.size" 8, "task.heartbeat.frequency.secs" 3, "topology.tasks" nil, "storm.messaging.netty.max_retries" 30, "topology.spout.wait.strategy" "backtype.storm.spout.SleepSpoutWaitStrategy", "nimbus.thrift.max_buffer_size" 1048576, "topology.max.spout.pending" nil, "storm.zookeeper.retry.interval" 1000, "topology.sleep.spout.wait.strategy.time.ms" 1, "nimbus.topology.validator" "backtype.storm.nimbus.DefaultTopologyValidator", "supervisor.slots.ports" [6700 6701 6702 6703], "topology.debug" false, "nimbus.task.launch.secs" 120, "nimbus.supervisor.timeout.secs" 60, "topology.message.timeout.secs" 30, "task.refresh.poll.secs" 10, "topology.workers" 1, "supervisor.childopts" "-Xmx256m", "nimbus.thrift.port" 6627, "topology.stats.sample.rate" 0.05, "worker.heartbeat.frequency.secs" 1, "topology.tuple.serializer" "backtype.storm.serialization.types.ListDelegateSerializer", "topology.disruptor.wait.strategy" "com.lmax.disruptor.BlockingWaitStrategy", "nimbus.task.timeout.secs" 30, "storm.zookeeper.connection.timeout" 15000, "topology.kryo.factory" "backtype.storm.serialization.DefaultKryoFactory", "drpc.invocations.port" 3773, "logviewer.port" 8000, "zmq.threads" 1, "storm.zookeeper.retry.times" 5, "storm.thrift.transport" "backtype.storm.security.auth.SimpleTransportPlugin", "topology.state.synchronization.timeout.secs" 60, "supervisor.worker.timeout.secs" 30, "nimbus.file.copy.expiration.secs" 600, "storm.messaging.transport" "backtype.storm.messaging.netty.Context", "logviewer.appender.name" "A1", "storm.messaging.netty.max_wait_ms" 1000, "drpc.request.timeout.secs" 600, "storm.local.mode.zmq" false, "ui.port" 8772, "nimbus.childopts" "-Xmx1024m", "storm.cluster.mode" "distributed", "topology.optimize" true, "topology.max.task.parallelism" nil}
2014-10-26 19:45:57 c.n.c.f.i.CuratorFrameworkImpl [INFO] Starting
2014-10-26 19:45:57 o.a.z.ZooKeeper [INFO] Initiating client connection, connectString=localhost:2181 sessionTimeout=20000 watcher=com.netflix.curator.ConnectionState@36a70903
2014-10-26 19:45:57 o.a.z.ClientCnxn [INFO] Opening socket connection to server localhost/127.0.0.1:2181
2014-10-26 19:45:57 o.a.z.ClientCnxn [INFO] Socket connection established to localhost/127.0.0.1:2181, initiating session
2014-10-26 19:45:57 o.a.z.ClientCnxn [INFO] Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x1494c96c985005e, negotiated timeout = 20000
2014-10-26 19:45:57 b.s.zookeeper [INFO] Zookeeper state update: :connected:none
2014-10-26 19:45:57 o.a.z.ZooKeeper [INFO] Session: 0x1494c96c985005e closed
2014-10-26 19:45:57 o.a.z.ClientCnxn [INFO] EventThread shut down
2014-10-26 19:45:57 c.n.c.f.i.CuratorFrameworkImpl [INFO] Starting
2014-10-26 19:45:57 o.a.z.ZooKeeper [INFO] Initiating client connection, connectString=localhost:2181/storm sessionTimeout=20000 watcher=com.netflix.curator.ConnectionState@7a4e6777
2014-10-26 19:45:57 o.a.z.ClientCnxn [INFO] Opening socket connection to server localhost/127.0.0.1:2181
2014-10-26 19:45:57 o.a.z.ClientCnxn [INFO] Socket connection established to localhost/127.0.0.1:2181, initiating session
2014-10-26 19:45:57 o.a.z.ClientCnxn [INFO] Session establishment complete on server localhost/127.0.0.1:2181, sessionid = 0x1494c96c985005f, negotiated timeout = 20000
2014-10-26 19:45:57 b.s.m.TransportFactory [INFO] Storm peer transport plugin:backtype.storm.messaging.netty.Context
2014-10-26 19:45:57 b.s.d.executor [INFO] Loading executor signal-spout:[2 2]
2014-10-26 19:45:57 b.s.d.worker [ERROR] Error on initialization of server mk-worker
java.lang.NoClassDefFoundError: backtype/storm/contrib/signals/spout/BaseSignalSpout
at java.lang.ClassLoader.defineClass1(Native Method) ~[na:1.6.0_32]
at java.lang.ClassLoader.defineClass(ClassLoader.java:643) ~[na:1.6.0_32]
at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142) ~[na:1.6.0_32]
at java.net.URLClassLoader.defineClass(URLClassLoader.java:277) ~[na:1.6.0_32]
at java.net.URLClassLoader.access$000(URLClassLoader.java:73) ~[na:1.6.0_32]
at java.net.URLClassLoader$1.run(URLClassLoader.java:212) ~[na:1.6.0_32]
at java.security.AccessController.doPrivileged(Native Method) ~[na:1.6.0_32]
at java.net.URLClassLoader.findClass(URLClassLoader.java:205) ~[na:1.6.0_32]
at java.lang.ClassLoader.loadClass(ClassLoader.java:323) ~[na:1.6.0_32]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:294) ~[na:1.6.0_32]
at java.lang.ClassLoader.loadClass(ClassLoader.java:268) ~[na:1.6.0_32]
at java.lang.Class.forName0(Native Method) ~[na:1.6.0_32]
at java.lang.Class.forName(Class.java:270) ~[na:1.6.0_32]
at java.io.ObjectInputStream.resolveClass(ObjectInputStream.java:624) ~[na:1.6.0_32]
at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1611) ~[na:1.6.0_32]
at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1516) ~[na:1.6.0_32]
at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1770) ~[na:1.6.0_32]
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1349) ~[na:1.6.0_32]
at java.io.ObjectInputStream.readObject(ObjectInputStream.java:369) ~[na:1.6.0_32]
at backtype.storm.utils.Utils.deserialize(Utils.java:82) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.utils.Utils.getSetComponentObject(Utils.java:218) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.daemon.task$get_task_object.invoke(task.clj:73) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.daemon.task$mk_task_data$fn__3402.invoke(task.clj:180) ~[na:na]
at backtype.storm.util$assoc_apply_self.invoke(util.clj:792) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.daemon.task$mk_task_data.invoke(task.clj:173) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.daemon.task$mk_task.invoke(task.clj:184) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.daemon.executor$mk_executor$fn__3785.invoke(executor.clj:320) ~[na:na]
at clojure.core$map$fn__4087.invoke(core.clj:2432) ~[clojure-1.4.0.jar:na]
at clojure.lang.LazySeq.sval(LazySeq.java:42) ~[clojure-1.4.0.jar:na]
at clojure.lang.LazySeq.seq(LazySeq.java:60) ~[clojure-1.4.0.jar:na]
at clojure.lang.RT.seq(RT.java:473) ~[clojure-1.4.0.jar:na]
at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.4.0.jar:na]
at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) ~[clojure-1.4.0.jar:na]
at clojure.core.protocols$fn__5875.invoke(protocols.clj:54) ~[clojure-1.4.0.jar:na]
at clojure.core.protocols$fn__5828$G__5823__5841.invoke(protocols.clj:13) ~[clojure-1.4.0.jar:na]
at clojure.core$reduce.invoke(core.clj:6030) ~[clojure-1.4.0.jar:na]
at clojure.core$into.invoke(core.clj:6077) ~[clojure-1.4.0.jar:na]
at backtype.storm.daemon.executor$mk_executor.invoke(executor.clj:320) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at backtype.storm.daemon.worker$eval4413$exec_fn__1102__auto____4414$iter__4419__4423$fn__4424.invoke(worker.clj:375) ~[na:na]
at clojure.lang.LazySeq.sval(LazySeq.java:42) ~[clojure-1.4.0.jar:na]
at clojure.lang.LazySeq.seq(LazySeq.java:60) ~[clojure-1.4.0.jar:na]
at clojure.lang.RT.seq(RT.java:473) ~[clojure-1.4.0.jar:na]
at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.4.0.jar:na]
at clojure.core$dorun.invoke(core.clj:2725) ~[clojure-1.4.0.jar:na]
at clojure.core$doall.invoke(core.clj:2741) ~[clojure-1.4.0.jar:na]
at backtype.storm.daemon.worker$eval4413$exec_fn__1102__auto____4414.invoke(worker.clj:375) ~[na:na]
at clojure.lang.AFn.applyToHelper(AFn.java:185) ~[clojure-1.4.0.jar:na]
at clojure.lang.AFn.applyTo(AFn.java:151) ~[clojure-1.4.0.jar:na]
at clojure.core$apply.invoke(core.clj:601) ~[clojure-1.4.0.jar:na]
at backtype.storm.daemon.worker$eval4413$mk_worker__4469.doInvoke(worker.clj:344) ~[na:na]
at clojure.lang.RestFn.invoke(RestFn.java:512) ~[clojure-1.4.0.jar:na]
at backtype.storm.daemon.worker$_main.invoke(worker.clj:454) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
at clojure.lang.AFn.applyToHelper(AFn.java:172) ~[clojure-1.4.0.jar:na]
at clojure.lang.AFn.applyTo(AFn.java:151) ~[clojure-1.4.0.jar:na]
at backtype.storm.daemon.worker.main(Unknown Source) ~[storm-core-0.9.1-incubating.jar:0.9.1-incubating]
Caused by: java.lang.ClassNotFoundException: backtype.storm.contrib.signals.spout.BaseSignalSpout
at java.net.URLClassLoader$1.run(URLClassLoader.java:217) ~[na:1.6.0_32]
at java.security.AccessController.doPrivileged(Native Method) ~[na:1.6.0_32]
at java.net.URLClassLoader.findClass(URLClassLoader.java:205) ~[na:1.6.0_32]
at java.lang.ClassLoader.loadClass(ClassLoader.java:323) ~[na:1.6.0_32]
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:294) ~[na:1.6.0_32]
at java.lang.ClassLoader.loadClass(ClassLoader.java:268) ~[na:1.6.0_32]
... 55 common frames omitted
2014-10-26 19:45:57 b.s.util [INFO] Halting process: ("Error on initialization")
