Shulou(Shulou.com)06/03 Report--

Recently, I saw a relatively simple example of storm processing in the book "getting started with storm", but there was a strange problem, the following code and output log.

The first is the spout class. Package spouts;import java.io.BufferedReader;import java.io.FileNotFoundException;import java.io.FileReader;import java.util.Map;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;public class WordReader extends BaseRichSpout {private SpoutOutputCollector collector; private FileReader fileReader; private boolean completed = false Public void ack (Object msgId) {System.out.println ("OK:" + msgId);} public void close () {} public void fail (Object msgId) {System.out.println ("FAIL:" + msgId) } / * * The only thing that the methods will do It is emit each * file line * / public void nextTuple () {/ * The nextuple it is called forever So if we have been readed the file * we will wait and then return * / if (completed) {try {Thread.sleep (1000) } catch (InterruptedException e) {/ / Do nothing} return;} String str; / / Open the reader BufferedReader reader = new BufferedReader (fileReader) Try {/ / Read all lines while ((str = reader.readLine ())! = null) {/ * * By each line emmit a new value with the line as a their * / this.collector.emit (new Values (str)) Str) }} catch (Exception e) {throw new RuntimeException ("Error reading tuple", e);} finally {completed = true }} / * We will create the file and get the collector object * / public void open (Map conf, TopologyContext context, SpoutOutputCollector collector) {try {this.fileReader = new FileReader (conf.get ("wordsFile") .toString ()) } catch (FileNotFoundException e) {throw new RuntimeException ("Error reading file [" + conf.get ("wordFile") + "]");} this.collector = collector } / * * Declare the output field "word" * / public void declareOutputFields (OutputFieldsDeclarer declarer) {declarer.declare (new Fields ("line"));}}

Then there are two bolt classes. WordNormalizer first normalizes the output from spout, and then passes it to WordCounter to complete the statistics.

Package bolts

Import backtype.storm.topology.BasicOutputCollector

Import backtype.storm.topology.OutputFieldsDeclarer

Import backtype.storm.topology.base.BaseBasicBolt

Import backtype.storm.tuple.Fields

Import backtype.storm.tuple.Tuple

Import backtype.storm.tuple.Values

Public class WordNormalizer extends BaseBasicBolt {

Public void cleanup () {}

/ * *

* The bolt will receive the line from the

* words file and process it to Normalize this line

*

* The normalize will be put the words in lower case

* and split the line to get all words in this

, /

Public void execute (Tuple input, BasicOutputCollector collector) {

String sentence = input.getString (0)

String [] words = sentence.split ("")

For (String word: words) {

Word = word.trim ()

If (! word.isEmpty ()) {

Word = word.toLowerCase ()

Collector.emit (new Values (word))

}

}

}

/ * *

* The bolt will only emit the field "word"

, /

Public void declareOutputFields (OutputFieldsDeclarer declarer) {

Declarer.declare (new Fields ("word"))

}

}

Package bolts

Import java.util.HashMap

Import java.util.Map

Import backtype.storm.task.TopologyContext

Import backtype.storm.topology.BasicOutputCollector

Import backtype.storm.topology.OutputFieldsDeclarer

Import backtype.storm.topology.base.BaseBasicBolt

Import backtype.storm.tuple.Tuple

Public class WordCounter extends BaseBasicBolt {

Integer id

String name

Map counters

/ * *

* At the end of the spout (when the cluster is shutdown

* We will show the word counters

, /

@ Override

Public void cleanup () {

System.err.println ("--Word Counter [" + name+ "-" + id+ "]--")

For (Map.Entry entry: counters.entrySet ()) {

System.err.println (entry.getKey () + ":" + entry.getValue ())

}

}

/ * *

* On create

, /

@ Override

Public void prepare (Map stormConf, TopologyContext context) {

This.counters = new HashMap ()

This.name = context.getThisComponentId ()

This.id = context.getThisTaskId ()

}

@ Override

Public void declareOutputFields (OutputFieldsDeclarer declarer) {}

@ Override

Public void execute (Tuple input, BasicOutputCollector collector) {

String str = input.getString (0)

/ * *

* If the word dosn't exist in the map we will create

* this, if not We will add 1

, /

If (! counters.containsKey (str)) {

Counters.put (str, 1)

} else {

Integer c = counters.get (str) + 1

Counters.put (str, c)

}

}

}

The following is the main class of the program.

Package spouts

Import java.io.BufferedReader

Import java.io.FileNotFoundException

Import java.io.FileReader

Import java.util.Map

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

Public class WordReader extends BaseRichSpout {

Private SpoutOutputCollector collector

Private FileReader fileReader

Private boolean completed = false

Public void ack (Object msgId) {

System.out.println ("OK:" + msgId)

}

Public void close () {}

Public void fail (Object msgId) {

System.out.println ("FAIL:" + msgId)

}

/ * *

* The only thing that the methods will do It is emit each

* file line

, /

Public void nextTuple () {

/ * *

* The nextuple it is called forever, so if we have been readed the file

* we will wait and then return

, /

If (completed) {

Try {

Thread.sleep (1000)

} catch (InterruptedException e) {

/ / Do nothing

}

Return

}

String str

/ / Open the reader

BufferedReader reader = new BufferedReader (fileReader)

Try {

/ / Read all lines

While ((str = reader.readLine ())! = null) {

/ * *

* By each line emmit a new value with the line as a their

, /

This.collector.emit (new Values (str), str)

}

} catch (Exception e) {

Throw new RuntimeException ("Error reading tuple", e)

} finally {

Completed = true

}

}

/ * *

* We will create the file and get the collector object

, /

Public void open (Map conf, TopologyContext context

SpoutOutputCollector collector) {

Try {

This.fileReader = new FileReader (conf.get ("wordsFile") .toString ())

} catch (FileNotFoundException e) {

Throw new RuntimeException ("Error reading file [" + conf.get ("wordFile") + "]")

}

This.collector = collector

}

/ * *

* Declare the output field "word"

, /

Public void declareOutputFields (OutputFieldsDeclarer declarer) {

Declarer.declare (new Fields ("line"))

}

}

By the way, there is also a data file.

Storm

Test

Are

Great

Is

An

Storm

Simple

Application

But

Very

Powerfull

Really

StOrm

Is

Great

The execution then runs to the end, but there is no expected output. The following is the output log. Since this test is done in myeclipse, there is no zookeeper. I have done similar tests before, and it is easy to get the results. I don't know what the problem is. I don't know if it's the code or the environment. Jdk is 1.6 and the storm is 0.9.3.

1277 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:zookeeper.version=3.4.6-1569965, built on 02 INFO org.apache.storm.zookeeper.ZooKeeper 2014 09:09 GMT

1278 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:host.name=PC201507010905

1278 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:java.version=1.6.0_13

1278 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:java.vendor=Sun Microsystems Inc.

1278 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:java.home=F:\ backup\ jiang\ MyEclipse\ MyEclipse\ Common\ binary\ com.sun.java.jdk.win32.x86_1.6.0.013\ jre

1279 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:java.class.path=E:\ my shenyang_4.0\ Storm_project\ bin;E:\ my shenyang_4.0\ Storm_project\ lib\ asm-4.0.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ carbonite-1.4.0.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ chill-java-0.3.5.jar E:\ my shenyang_4.0\ Storm_project\ lib\ clj-stacktrace-0.2.2.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ clj-time-0.4.1.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ clojure-1.5.1.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ clout-1.0.1.jar E:\ my shenyang_4.0\ Storm_project\ lib\ commons-codec-1.6.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ commons-exec-1.1.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ commons-fileupload-1.2.1.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ commons-io-2.4.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ commons-lang-2.5.jar E:\ my shenyang_4.0\ Storm_project\ lib\ commons-logging-1.1.3.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ compojure-1.1.3.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ core.incubator-0.1.0.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ disruptor-2.10.1.jar E:\ my shenyang_4.0\ Storm_project\ lib\ hiccup-0.3.6.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ jetty-6.1.26.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ jetty-util-6.1.26.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ jgrapht-core-0.9.0.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ jline-2.11.jar E:\ my shenyang_4.0\ Storm_project\ lib\ joda-time-2.0.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ json-simple-1.1.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ kryo-2.21.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ log4j-over-slf4j-1.6.6.jar E:\ my shenyang_4.0\ Storm_project\ lib\ logback-classic-1.0.13.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ logback-core-1.0.13.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ math.numeric-tower-0.0.1.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ minlog-1.2.jar E:\ my shenyang_4.0\ Storm_project\ lib\ objenesis-1.2.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ reflectasm-1.07-shaded.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ ring-core-1.1.5.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ ring-devel-0.3.11.jar E:\ my shenyang_4.0\ Storm_project\ lib\ ring-jetty-adapter-0.3.11.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ ring-servlet-0.3.11.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ servlet-api-2.5.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ slf4j-api-1.7.5.jar E:\ my shenyang_4.0\ Storm_project\ lib\ snakeyaml-1.11.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ storm-core-0.9.3.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ tools.cli-0.2.4.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ tools.logging-0.2.3.jar E:\ my shenyang_4.0\ Storm_project\ lib\ tools.macro-0.1.0.jar

1281 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:java.library.path=F:\ backup\ jiang\ MyEclipse\ MyEclipse\ Common\ binary\ com.sun.java.jdk.win32.x86_1.6.0.013\ bin;.;C:\ Windows\ Sun\ Java\ bin;C:\ Windows\ system32;C:\ Windows;F:/backup/jiang/MyEclipse/MyEclipse/Common/binary/com.sun.java.jdk.win32.x86_1.6.0.013/jre/bin/client Javapath;F:\ app\ Administrator\ product\ 11.2.0\ client_1\ bin;c:\ gtk\ bin;C:\ Windows\ system32;C:\ Windows C:\ Windows\ System32\ Wbem;C:\ Windows\ System32\ WindowsPowerShell\ v1.0; D:\ oracle\ yang\ oracle10g;C:\ Program Files\ Java\ jdk1.8.0_51;C:\ Program Files (x86)\ Microsoft SQL Server\ 100\ Tools\ Binn\; C:\ Program Files\ Microsoft SQL Server\ 100\ Tools\ Binn\; C:\ Program Files\ Microsoft SQL Server\ 100\ DTS\ Binn\; C:\ Program Files (x86)\ Microsoft SQL Server\ 100\ Tools\ Binn\ VSShell\ Common7\ IDE C:\ Program Files (x86)\ Microsoft Visual Studio 9.0\ Common7\ IDE\ PrivateAssemblies; C:\ Program Files (x86)\ Microsoft SQL Server\ 100\ DTS\ Binn\; C:\ apache-ant-1.9.6\ bin;C:\ Program Files\ Java\ jdk1.8.0_51\ bin;C:\ PROGRA~2\ IBM\ SQLLIB\ BIN;C:\ PROGRA~2\ IBM\ SQLLIB\ FUNCTION;C:\ PROGRA~2\ IBM\ SQLLIB\ SAMPLES\ REPL;C:\ Program Files (x86)\ IDM Computer Solutions\ UltraEdit\

1281 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:java.io.tmpdir=C:\ Users\ ADMINI~1\ AppData\ Local\ Temp\

1281 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:java.compiler=

1281 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:os.name=Windows Vista

1281 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:os.arch=x86

1281 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:os.version=6.1

1281 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:user.name=Administrator

1281 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:user.home=C:\ Users\ Administrator

1281 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Client environment:user.dir=E:\ my shenyang_4.0\ Storm_project

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:zookeeper.version=3.4.6-1569965, built on 02 INFO org.apache.storm.zookeeper.server.ZooKeeperServer 2014 09:09 GMT

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:host.name=PC201507010905

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:java.version=1.6.0_13

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:java.vendor=Sun Microsystems Inc.

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:java.home=F:\ backup\ jiang\ MyEclipse\ MyEclipse\ Common\ binary\ com.sun.java.jdk.win32.x86_1.6.0.013\ jre

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:java.class.path=E:\ my shenyang_4.0\ Storm_project\ bin;E:\ my shenyang_4.0\ Storm_project\ lib\ asm-4.0.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ carbonite-1.4.0.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ chill-java-0.3.5.jar E:\ my shenyang_4.0\ Storm_project\ lib\ clj-stacktrace-0.2.2.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ clj-time-0.4.1.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ clojure-1.5.1.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ clout-1.0.1.jar E:\ my shenyang_4.0\ Storm_project\ lib\ commons-codec-1.6.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ commons-exec-1.1.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ commons-fileupload-1.2.1.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ commons-io-2.4.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ commons-lang-2.5.jar E:\ my shenyang_4.0\ Storm_project\ lib\ commons-logging-1.1.3.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ compojure-1.1.3.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ core.incubator-0.1.0.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ disruptor-2.10.1.jar E:\ my shenyang_4.0\ Storm_project\ lib\ hiccup-0.3.6.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ jetty-6.1.26.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ jetty-util-6.1.26.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ jgrapht-core-0.9.0.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ jline-2.11.jar E:\ my shenyang_4.0\ Storm_project\ lib\ joda-time-2.0.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ json-simple-1.1.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ kryo-2.21.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ log4j-over-slf4j-1.6.6.jar E:\ my shenyang_4.0\ Storm_project\ lib\ logback-classic-1.0.13.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ logback-core-1.0.13.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ math.numeric-tower-0.0.1.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ minlog-1.2.jar E:\ my shenyang_4.0\ Storm_project\ lib\ objenesis-1.2.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ reflectasm-1.07-shaded.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ ring-core-1.1.5.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ ring-devel-0.3.11.jar E:\ my shenyang_4.0\ Storm_project\ lib\ ring-jetty-adapter-0.3.11.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ ring-servlet-0.3.11.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ servlet-api-2.5.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ slf4j-api-1.7.5.jar E:\ my shenyang_4.0\ Storm_project\ lib\ snakeyaml-1.11.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ storm-core-0.9.3.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ tools.cli-0.2.4.jar;E:\ my shenyang_4.0\ Storm_project\ lib\ tools.logging-0.2.3.jar E:\ my shenyang_4.0\ Storm_project\ lib\ tools.macro-0.1.0.jar

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:java.library.path=F:\ backup\ jiang\ MyEclipse\ MyEclipse\ Common\ binary\ com.sun.java.jdk.win32.x86_1.6.0.013\ bin;.;C:\ Windows\ Sun\ Java\ bin;C:\ Windows\ system32;C:\ Windows;F:/backup/jiang/MyEclipse/MyEclipse/Common/binary/com.sun.java.jdk.win32.x86_1.6.0.013/jre/bin/client Javapath;F:\ app\ Administrator\ product\ 11.2.0\ client_1\ bin;c:\ gtk\ bin;C:\ Windows\ system32;C:\ Windows C:\ Windows\ System32\ Wbem;C:\ Windows\ System32\ WindowsPowerShell\ v1.0; D:\ oracle\ yang\ oracle10g;C:\ Program Files\ Java\ jdk1.8.0_51;C:\ Program Files (x86)\ Microsoft SQL Server\ 100\ Tools\ Binn\; C:\ Program Files\ Microsoft SQL Server\ 100\ Tools\ Binn\; C:\ Program Files\ Microsoft SQL Server\ 100\ DTS\ Binn\; C:\ Program Files (x86)\ Microsoft SQL Server\ 100\ Tools\ Binn\ VSShell\ Common7\ IDE C:\ Program Files (x86)\ Microsoft Visual Studio 9.0\ Common7\ IDE\ PrivateAssemblies; C:\ Program Files (x86)\ Microsoft SQL Server\ 100\ DTS\ Binn\; C:\ apache-ant-1.9.6\ bin;C:\ Program Files\ Java\ jdk1.8.0_51\ bin;C:\ PROGRA~2\ IBM\ SQLLIB\ BIN;C:\ PROGRA~2\ IBM\ SQLLIB\ FUNCTION;C:\ PROGRA~2\ IBM\ SQLLIB\ SAMPLES\ REPL;C:\ Program Files (x86)\ IDM Computer Solutions\ UltraEdit\

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:java.io.tmpdir=C:\ Users\ ADMINI~1\ AppData\ Local\ Temp\

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:java.compiler=

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:os.name=Windows Vista

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:os.arch=x86

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:os.version=6.1

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:user.name=Administrator

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:user.home=C:\ Users\ Administrator

1289 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Server environment:user.dir=E:\ my shenyang_4.0\ Storm_project

1634 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Created server with tickTime 2000 minSessionTimeout 4000 maxSessionTimeout 40000 datadir C:\ Users\ ADMINI~1\ AppData\ Local\ Temp\ dfd81caa-cc57-42c9-ba21-11ccac776aff\ version-2 snapdir C:\ Users\ ADMINI~1\ AppData\ Local\ Temp\ dfd81caa-cc57-42c9-ba21-11ccac776aff\ version-2

1638 [main] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-binding to port 0.0.0.0Plus 0.0.0.0pur2000

1640 [main] INFO backtype.storm.zookeeper-Starting inprocess zookeeper at port 2000 and dir C:\ Users\ ADMINI~1\ AppData\ Local\ Temp\ dfd81caa-cc57-42c9-ba21-11ccac776aff

1740 [main] INFO backtype.storm.daemon.nimbus-Starting Nimbus with 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" 0, "topology.skip.missing.kryo.registrations" true "storm.messaging.netty.client_worker_threads" 1, "ui.childopts"- Xmx768m", "storm.zookeeper.session.timeout" 20000, "nimbus.reassign" true, "topology.trident.batch.emit.interval.millis" 50, "storm.messaging.netty.flush.check.interval.ms" 10, "nimbus.monitor.freq.secs" 10, "logviewer.childopts"- Xmx128m" "java.library.path"/ usr/local/lib:/opt/local/lib:/usr/lib", "topology.executor.send.buffer.size" 1024, "storm.local.dir"C:\\ Users\\ ADMINI~1\\ AppData\\ Local\\ Temp\\ a49e6cc7-163f-483c-acc5-b7ef66811e93", "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, "storm.meta.serialization.delegate"backtype.storm.serialization.DefaultSerializationDelegate", "topology.worker.shared.thread.pool.size" 4, "nimbus.host"localhost", "storm.messaging.netty.min_wait_ms" 2000, "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" 300, "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.environment" nil, "topology.debug" false, "nimbus.task.launch.secs" 120,60 "nimbus.supervisor.timeout.secs", "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", "topology.multilang.serializer"backtype.storm.multilang.JsonSerializer", "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, "topology.worker.receiver.thread.count" 1, "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" 262144, "storm.local.mode.zmq" false, "ui.port" 8080, "nimbus.childopts"-Xmx1024m "," storm.cluster.mode "" local "," topology.max.task.parallelism "nil," storm.messaging.netty.transfer.batch.size "262144," topology.classpath "nil}

1743 [main] INFO backtype.storm.daemon.nimbus-Using default scheduler

1750 [main] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry-The baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [5]

1785 [main] INFO org.apache.storm.curator.framework.imps.CuratorFrameworkImpl-Starting

1788 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Initiating client connection, connectString=localhost:2000 sessionTimeout=20000 watcher=org.apache.storm.curator.ConnectionState@1264666

1800 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 127.0.0.1 Universe 2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

1800 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Socket connection established to 127.0.0.1 Univer 2000, initiating session

1800 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-Accepted socket connection from / 127.0.0.1 purl 52191

1804 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Client attempting to establish new session at / 127.0.0.1 purl 52191

1805 [SyncThread:0] INFO org.apache.storm.zookeeper.server.persistence.FileTxnLog-Creating new log file: log.1

1852 [SyncThread:0] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Established session 0x1549474265a0000 with negotiated timeout 20000 for client / 127.0.0.1 purl 52191

1853 [main-SendThread (127.0.0.1 Session establishment complete on server 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Session establishment complete on server 127.0.0.1 Unix 2000, sessionid = 0x1549474265a0000, negotiated timeout = 20000

1854 [main-EventThread] INFO org.apache.storm.curator.framework.state.ConnectionStateManager-State change: CONNECTED

1855 [main-EventThread] INFO backtype.storm.zookeeper-Zookeeper state update:: connected:none

2935 [ProcessThread (sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor-Processed session termination for sessionid: 0x1549474265a0000

2948 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Session: 0x1549474265a0000 closed

2948 [main-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn-EventThread shut down

2949 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxn-Closed socket connection for client / 127.0.0.1 Closed socket connection for client 52191 which had sessionid 0x1549474265a0000

2950 [main] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry-The baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [5]

2950 [main] INFO org.apache.storm.curator.framework.imps.CuratorFrameworkImpl-Starting

2951 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.curator.ConnectionState@12b72f4

2954 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 127.0.0.1 Universe 2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

2954 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Socket connection established to 127.0.0.1 Univer 2000, initiating session

2954 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-Accepted socket connection from / 127.0.0.1 purl 52194

2955 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Client attempting to establish new session at / 127.0.0.1 purl 52194

2972 [SyncThread:0] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Established session 0x1549474265a0001 with negotiated timeout 20000 for client / 127.0.0.1 purl 52194

2973 [main-SendThread (127.0.0.1 Session establishment complete on server 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Session establishment complete on server 127.0.0.1 Unix 2000, sessionid = 0x1549474265a0001, negotiated timeout = 20000

2973 [main-EventThread] INFO org.apache.storm.curator.framework.state.ConnectionStateManager-State change: CONNECTED

3108 [main] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry-The baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [5]

3109 [main] INFO org.apache.storm.curator.framework.imps.CuratorFrameworkImpl-Starting

3109 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Initiating client connection, connectString=localhost:2000 sessionTimeout=20000 watcher=org.apache.storm.curator.ConnectionState@26efd3

3111 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 127.0.0.1 Universe 2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

3112 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Socket connection established to 127.0.0.1 Univer 2000, initiating session

3112 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-Accepted socket connection from / 127.0.0.1 purl 52197

3112 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Client attempting to establish new session at / 127.0.0.1 purl 52197

3131 [SyncThread:0] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Established session 0x1549474265a0002 with negotiated timeout 20000 for client / 127.0.0.1 purl 52197

3131 [main-SendThread (127.0.0.1 Session establishment complete on server 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Session establishment complete on server 127.0.0.1 Unix 2000, sessionid = 0x1549474265a0002, negotiated timeout = 20000

3131 [main-EventThread] INFO org.apache.storm.curator.framework.state.ConnectionStateManager-State change: CONNECTED

3131 [main-EventThread] INFO backtype.storm.zookeeper-Zookeeper state update:: connected:none

3133 [ProcessThread (sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor-Processed session termination for sessionid: 0x1549474265a0002

3155 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Session: 0x1549474265a0002 closed

3156 [main-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn-EventThread shut down

3156 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxn-Closed socket connection for client / 127.0.0.1 Closed socket connection for client 52197 which had sessionid 0x1549474265a0002

3156 [main] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry-The baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [5]

3156 [main] INFO org.apache.storm.curator.framework.imps.CuratorFrameworkImpl-Starting

3156 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.curator.ConnectionState@11201a1

3158 [main] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry-The baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [5]

3158 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 127.0.0.1 Universe 2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

3158 [main] INFO org.apache.storm.curator.framework.imps.CuratorFrameworkImpl-Starting

3158 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-Accepted socket connection from / 127.0.0.1 purl 52200

3159 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Initiating client connection, connectString=localhost:2000 sessionTimeout=20000 watcher=org.apache.storm.curator.ConnectionState@1c1f2

3159 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Socket connection established to 127.0.0.1 Univer 2000, initiating session

3159 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Client attempting to establish new session at / 127.0.0.1 purl 52200

3160 [main-SendThread] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 0VOV 0VOUL2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 0VOVO VOULO VOULO VOUL0VOUL0VOUL0VOULO 0VOUL0VOULO 0Vl0VULlG00VlGUL2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

3161 [main-SendThread (0 Unable to open socket to 0, 0) 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,

3164 [main-SendThread (0 Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect)]

Java.net.SocketException: Address family not supported by protocol family: connect

At sun.nio.ch.Net.connect (Native Method) ~ [na:1.6.0_13]

At sun.nio.ch.SocketChannelImpl.connect (SocketChannelImpl.java:507) ~ [na:1.6.0_13]

At org.apache.storm.zookeeper.ClientCnxnSocketNIO.registerAndConnect (ClientCnxnSocketNIO.java:277) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxnSocketNIO.connect (ClientCnxnSocketNIO.java:287) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxn$SendThread.startConnect (ClientCnxn.java:967) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxn$SendThread.run (ClientCnxn.java:1003) ~ [storm-core-0.9.3.jar:0.9.3]

3172 [SyncThread:0] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Established session 0x1549474265a0003 with negotiated timeout 20000 for client / 127.0.0.1 purl 52200

3172 [main-SendThread (127.0.0.1 Session establishment complete on server 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Session establishment complete on server 127.0.0.1 Unix 2000, sessionid = 0x1549474265a0003, negotiated timeout = 20000

3172 [main-EventThread] INFO org.apache.storm.curator.framework.state.ConnectionStateManager-State change: CONNECTED

3264 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 127.0.0.1 Universe 2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

3265 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Socket connection established to 127.0.0.1 Univer 2000, initiating session

3265 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-Accepted socket connection from / 127.0.0.1 purl 52203

3265 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Client attempting to establish new session at / 127.0.0.1 purl 52203

3281 [SyncThread:0] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Established session 0x1549474265a0004 with negotiated timeout 20000 for client / 127.0.0.1 purl 52203

3281 [main-SendThread (127.0.0.1 Session establishment complete on server 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Session establishment complete on server 127.0.0.1 Unix 2000, sessionid = 0x1549474265a0004, negotiated timeout = 20000

3281 [main-EventThread] INFO org.apache.storm.curator.framework.state.ConnectionStateManager-State change: CONNECTED

3281 [main-EventThread] INFO backtype.storm.zookeeper-Zookeeper state update:: connected:none

3284 [ProcessThread (sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor-Processed session termination for sessionid: 0x1549474265a0004

3297 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Session: 0x1549474265a0004 closed

3297 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxn-Closed socket connection for client / 127.0.0.1 Closed socket connection for client 52203 which had sessionid 0x1549474265a0004

3297 [main] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry-The baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [5]

3298 [main-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn-EventThread shut down

3298 [main] INFO org.apache.storm.curator.framework.imps.CuratorFrameworkImpl-Starting

3298 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.curator.ConnectionState@8c5488

3301 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 127.0.0.1 Universe 2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

3301 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Socket connection established to 127.0.0.1 Univer 2000, initiating session

3301 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-Accepted socket connection from / 127.0.0.1 purl 52206

3302 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Client attempting to establish new session at / 127.0.0.1 purl 52206

3322 [SyncThread:0] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Established session 0x1549474265a0005 with negotiated timeout 20000 for client / 127.0.0.1 purl 52206

3322 [main-SendThread (127.0.0.1 Session establishment complete on server 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Session establishment complete on server 127.0.0.1 Unix 2000, sessionid = 0x1549474265a0005, negotiated timeout = 20000

3323 [main-EventThread] INFO org.apache.storm.curator.framework.state.ConnectionStateManager-State change: CONNECTED

3332 [main] INFO backtype.storm.daemon.supervisor-Starting Supervisor with 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" 0, "topology.skip.missing.kryo.registrations" true "storm.messaging.netty.client_worker_threads" 1, "ui.childopts"- Xmx768m", "storm.zookeeper.session.timeout" 20000, "nimbus.reassign" true, "topology.trident.batch.emit.interval.millis" 50, "storm.messaging.netty.flush.check.interval.ms" 10, "nimbus.monitor.freq.secs" 10, "logviewer.childopts"- Xmx128m" "java.library.path"/ usr/local/lib:/opt/local/lib:/usr/lib", "topology.executor.send.buffer.size" 1024, "storm.local.dir"C:\\ Users\\ ADMINI~1\\ AppData\\ Local\\ Temp\\ 43b32479-d481-4c24-8688-3eada2523a5e", "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, "storm.meta.serialization.delegate"backtype.storm.serialization.DefaultSerializationDelegate", "topology.worker.shared.thread.pool.size" 4, "nimbus.host"localhost", "storm.messaging.netty.min_wait_ms" 2000, "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" 300, "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" (1024 1025 1026) "topology.environment" nil, "topology.debug" false, "nimbus.task.launch.secs" 120,60 "nimbus.supervisor.timeout.secs", "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", "topology.multilang.serializer"backtype.storm.multilang.JsonSerializer", "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, "topology.worker.receiver.thread.count" 1, "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" 262144, "storm.local.mode.zmq" false, "ui.port" 8080, "nimbus.childopts"-Xmx1024m "," storm.cluster.mode "" local "," topology.max.task.parallelism "nil," storm.messaging.netty.transfer.batch.size "262144," topology.classpath "nil}

3352 [main] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry-The baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [5]

3352 [main] INFO org.apache.storm.curator.framework.imps.CuratorFrameworkImpl-Starting

3352 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Initiating client connection, connectString=localhost:2000 sessionTimeout=20000 watcher=org.apache.storm.curator.ConnectionState@19422d2

3354 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 127.0.0.1 Universe 2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

3354 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Socket connection established to 127.0.0.1 Univer 2000, initiating session

3354 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-Accepted socket connection from / 127.0.0.1 purl 52209

3355 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Client attempting to establish new session at / 127.0.0.1 purl 52209

3372 [SyncThread:0] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Established session 0x1549474265a0006 with negotiated timeout 20000 for client / 127.0.0.1 purl 52209

3372 [main-SendThread (127.0.0.1 Session establishment complete on server 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Session establishment complete on server 127.0.0.1 Unix 2000, sessionid = 0x1549474265a0006, negotiated timeout = 20000

3372 [main-EventThread] INFO org.apache.storm.curator.framework.state.ConnectionStateManager-State change: CONNECTED

3373 [main-EventThread] INFO backtype.storm.zookeeper-Zookeeper state update:: connected:none

3373 [ProcessThread (sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor-Processed session termination for sessionid: 0x1549474265a0006

3397 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Session: 0x1549474265a0006 closed

3397 [main-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn-EventThread shut down

3397 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxn-Closed socket connection for client / 127.0.0.1 Closed socket connection for client 52209 which had sessionid 0x1549474265a0006

3397 [main] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry-The baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [5]

3397 [main] INFO org.apache.storm.curator.framework.imps.CuratorFrameworkImpl-Starting

3398 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.curator.ConnectionState@ef9525

3399 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 127.0.0.1 Universe 2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

3399 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Socket connection established to 127.0.0.1 Univer 2000, initiating session

3400 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-Accepted socket connection from / 127.0.0.1 purl 52212

3400 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Client attempting to establish new session at / 127.0.0.1 purl 52212

3414 [SyncThread:0] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Established session 0x1549474265a0007 with negotiated timeout 20000 for client / 127.0.0.1 purl 52212

3414 [main-SendThread (127.0.0.1 Session establishment complete on server 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Session establishment complete on server 127.0.0.1 Unix 2000, sessionid = 0x1549474265a0007, negotiated timeout = 20000

3415 [main-EventThread] INFO org.apache.storm.curator.framework.state.ConnectionStateManager-State change: CONNECTED

3465 [main] INFO backtype.storm.daemon.supervisor-Starting supervisor with id 2da9a25c-7c2e-40ce-bce4-e5995a3e15c7 at host PC201507010905

3468 [main] INFO backtype.storm.daemon.supervisor-Starting Supervisor with 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" 0, "topology.skip.missing.kryo.registrations" true "storm.messaging.netty.client_worker_threads" 1, "ui.childopts"- Xmx768m", "storm.zookeeper.session.timeout" 20000, "nimbus.reassign" true, "topology.trident.batch.emit.interval.millis" 50, "storm.messaging.netty.flush.check.interval.ms" 10, "nimbus.monitor.freq.secs" 10, "logviewer.childopts"- Xmx128m" "java.library.path"/ usr/local/lib:/opt/local/lib:/usr/lib", "topology.executor.send.buffer.size" 1024, "storm.local.dir"C:\\ Users\\ ADMINI~1\\ AppData\\ Local\\ Temp\\ 4bba3e0c-c4f4-4a90-b520-51168b660791", "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, "storm.meta.serialization.delegate"backtype.storm.serialization.DefaultSerializationDelegate", "topology.worker.shared.thread.pool.size" 4, "nimbus.host"localhost", "storm.messaging.netty.min_wait_ms" 2000, "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" 300, "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" (1027 1028 1029) "topology.environment" nil, "topology.debug" false, "nimbus.task.launch.secs" 120,60 "nimbus.supervisor.timeout.secs", "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", "topology.multilang.serializer"backtype.storm.multilang.JsonSerializer", "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, "topology.worker.receiver.thread.count" 1, "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" 262144, "storm.local.mode.zmq" false, "ui.port" 8080, "nimbus.childopts"-Xmx1024m "," storm.cluster.mode "" local "," topology.max.task.parallelism "nil," storm.messaging.netty.transfer.batch.size "262144," topology.classpath "nil}

3477 [main] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry-The baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [5]

3477 [main] INFO org.apache.storm.curator.framework.imps.CuratorFrameworkImpl-Starting

3478 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Initiating client connection, connectString=localhost:2000 sessionTimeout=20000 watcher=org.apache.storm.curator.ConnectionState@11a59ce

3480 [main-SendThread] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 0VOV 0VOUL2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 0VOVO VOULO VOULO VOUL0VOUL0VOUL0VOULO 0VOUL0VOULO 0Vl0VULlG00VlGUL2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

3480 [main-SendThread (0 Unable to open socket to 0, 0) 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,

3480 [main-SendThread (0 Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect)]

Java.net.SocketException: Address family not supported by protocol family: connect

At sun.nio.ch.Net.connect (Native Method) ~ [na:1.6.0_13]

At sun.nio.ch.SocketChannelImpl.connect (SocketChannelImpl.java:507) ~ [na:1.6.0_13]

At org.apache.storm.zookeeper.ClientCnxnSocketNIO.registerAndConnect (ClientCnxnSocketNIO.java:277) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxnSocketNIO.connect (ClientCnxnSocketNIO.java:287) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxn$SendThread.startConnect (ClientCnxn.java:967) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxn$SendThread.run (ClientCnxn.java:1003) ~ [storm-core-0.9.3.jar:0.9.3]

3580 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 127.0.0.1 Universe 2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

3581 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Socket connection established to 127.0.0.1 Univer 2000, initiating session

3581 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-Accepted socket connection from / 127.0.0.1 purl 52215

3581 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Client attempting to establish new session at / 127.0.0.1 purl 52215

3598 [SyncThread:0] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Established session 0x1549474265a0008 with negotiated timeout 20000 for client / 127.0.0.1 purl 52215

3598 [main-SendThread (127.0.0.1 Session establishment complete on server 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Session establishment complete on server 127.0.0.1 Unix 2000, sessionid = 0x1549474265a0008, negotiated timeout = 20000

3598 [main-EventThread] INFO org.apache.storm.curator.framework.state.ConnectionStateManager-State change: CONNECTED

3599 [main-EventThread] INFO backtype.storm.zookeeper-Zookeeper state update:: connected:none

3602 [ProcessThread (sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor-Processed session termination for sessionid: 0x1549474265a0008

3614 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Session: 0x1549474265a0008 closed

3615 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxn-Closed socket connection for client / 127.0.0.1 Closed socket connection for client 52215 which had sessionid 0x1549474265a0008

3615 [main] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry-The baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [5]

3615 [main-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn-EventThread shut down

3616 [main] INFO org.apache.storm.curator.framework.imps.CuratorFrameworkImpl-Starting

3616 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.curator.ConnectionState@1be8bf1

3620 [main-SendThread] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 0VOV 0VOUL2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 0VOVO VOULO VOULO VOUL0VOUL0VOUL0VOULO 0VOUL0VOULO 0Vl0VULlG00VlGUL2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

3620 [main-SendThread (0 Unable to open socket to 0, 0) 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,

3621 [main-SendThread (0 Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect)]

Java.net.SocketException: Address family not supported by protocol family: connect

At sun.nio.ch.Net.connect (Native Method) ~ [na:1.6.0_13]

At sun.nio.ch.SocketChannelImpl.connect (SocketChannelImpl.java:507) ~ [na:1.6.0_13]

At org.apache.storm.zookeeper.ClientCnxnSocketNIO.registerAndConnect (ClientCnxnSocketNIO.java:277) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxnSocketNIO.connect (ClientCnxnSocketNIO.java:287) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxn$SendThread.startConnect (ClientCnxn.java:967) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxn$SendThread.run (ClientCnxn.java:1003) ~ [storm-core-0.9.3.jar:0.9.3]

3721 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 127.0.0.1 Universe 2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

3721 [main-SendThread (127.0.0.1 main-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Socket connection established to 127.0.0.1 Univer 2000, initiating session

3721 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-Accepted socket connection from / 127.0.0.1 purl 52218

3722 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Client attempting to establish new session at / 127.0.0.1 purl 52218

3739 [SyncThread:0] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Established session 0x1549474265a0009 with negotiated timeout 20000 for client / 127.0.0.1 purl 52218

3739 [main-SendThread (127.0.0.1 Session establishment complete on server 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Session establishment complete on server 127.0.0.1 Unix 2000, sessionid = 0x1549474265a0009, negotiated timeout = 20000

3739 [main-EventThread] INFO org.apache.storm.curator.framework.state.ConnectionStateManager-State change: CONNECTED

3764 [main] INFO backtype.storm.daemon.supervisor-Starting supervisor with id 52ca5c90-e7f4-471e-ad8b-b66fa7f3569b at host PC201507010905

3799 [main] INFO backtype.storm.daemon.nimbus-Received topology submission for Getting-Started-Toplogie with conf {"topology.max.task.parallelism" nil, "topology.acker.executors" nil, "topology.kryo.register" nil, "topology.kryo.decorators" (), "topology.name"Getting-Started-Toplogie", "storm.id"Getting-Started-Toplogie-1-1462779522", "wordsFile"D:/BigData/storm/words.txt", "topology.debug" false "topology.max.spout.pending" 1}

3834 [main] INFO backtype.storm.daemon.nimbus-Activating Getting-Started-Toplogie: Getting-Started-Toplogie-1-1462779522

3907 [main] INFO backtype.storm.scheduler.EvenScheduler-Available slots: (["52ca5c90-e7f4-471e-ad8b-b66fa7f3569b" 1027] ["52ca5c90-e7f4-471e-ad8b-b66fa7f3569b" 1028] ["52ca5c90-e7f4-471e-ad8b-b66fa7f3569b" 1029] ["2da9a25c-7c2e-40ce-bce4-e5995a3e15c7" 1024] ["2da9a25c-7c2e-40ce-bce4-e5995a3e15c7" 1025] ["2da9a25c-7c2e-40ce-bce4-e5995a3e15c7" 1026])

3920 [main] INFO backtype.storm.daemon.nimbus-Setting new assignment for topology id Getting-Started-Toplogie-1-1462779522: # backtype.storm.daemon.common.Assignment {: master-code-dir "C:\\ Users\\ ADMINI~1\\ AppData\\ Local\\ Temp\\ a49e6cc7-163f-483c-acc5-b7ef66811e93\\ nimbus\\ stormdist\\ Getting-Started-Toplogie-1-1462779522", node- > host {"52ca5c90-e7f4-471e-ad8b-b66fa7f3569b"PC201507010905"} Executor- > node+port {[3 3] ["52ca5c90-e7f4-471e-ad8b-b66fa7f3569b" 1027], [4 4] ["52ca5c90-e7f4-471e-ad8b-b66fa7f3569b" 1027], [22] ["52ca5c90-e7f4-471e-ad8b-b66fa7f3569b" 1027], [1] ["52ca5c90-e7f4-471e-ad8b-b66fa7f3569b" 1027]}, executor- > start-time-secs {[4 4] 1462779522, [3 3] 1462779522, [22] 1462779522, [1] 1462779522}}

4539 [Thread-5] INFO backtype.storm.daemon.supervisor-Downloading code for storm id Getting-Started-Toplogie-1-1462779522 from C:\ Users\ ADMINI~1\ AppData\ Local\ Temp\ a49e6cc7-163f-483c-acc5-b7ef66811e93\ nimbus\ stormdist\ Getting-Started-Toplogie-1-1462779522

4758 [Thread-5] INFO backtype.storm.daemon.supervisor-Finished downloading code for storm id Getting-Started-Toplogie-1-1462779522 from C:\ Users\ ADMINI~1\ AppData\ Local\ Temp\ a49e6cc7-163f-483c-acc5-b7ef66811e93\ nimbus\ stormdist\ Getting-Started-Toplogie-1-1462779522

4790 [Thread-6] INFO backtype.storm.daemon.supervisor-Launching worker with assignment # backtype.storm.daemon.supervisor.LocalAssignment {: storm-id "Getting-Started-Toplogie-1-1462779522",: executors ([3 3] [4 4] [22] [1 1])} for this supervisor 52ca5c90-e7f4-471e-ad8b-b66fa7f3569b on port 1027 with id c64355a8-46e2-4880-80f0-0c3cb41eba52

4791 [Thread-6] INFO backtype.storm.daemon.worker-Launching worker for Getting-Started-Toplogie-1-1462779522 on 52ca5c90-e7f4-471e-ad8b-b66fa7f3569b:1027 with id c64355a8-46e2-4880-80f0-0c3cb41eba52 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" 0, "topology.skip.missing.kryo.registrations" true, "storm.messaging.netty.client_worker_threads" 1, "ui.childopts"-Xmx768m "," storm.zookeeper.session.timeout "20000," nimbus.reassign "true," topology.trident.batch.emit.interval.millis "50," storm.messaging.netty.flush.check.interval.ms "10 "nimbus.monitor.freq.secs" 10, "logviewer.childopts"- Xmx128m", "java.library.path"/ usr/local/lib:/opt/local/lib:/usr/lib", "topology.executor.send.buffer.size" 1024, "storm.local.dir"C:\\ Users\\ ADMINI~1\\ AppData\\ Local\\ Temp\\ 4bba3e0c-c4f4-4a90-b520-51168b660791", "storm.messaging.netty.buffer_size" 5242880 "supervisor.worker.start.timeout.secs" 120, "topology.enable.message.timeouts" true, "nimbus.cleanup.inbox.freq.secs" 3600, "drpc.worker.threads" 64, "storm.meta.serialization.delegate"backtype.storm.serialization.DefaultSerializationDelegate", "topology.worker.shared.thread.pool.size" 4, "nimbus.host"localhost", "storm.messaging.netty.min_wait_ms" 100 "storm.zookeeper.port" 2000, "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" 300, "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" (1027 1028 1029), "topology.environment" nil, "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" 6627 "worker.heartbeat.frequency.secs" 1, "topology.tuple.serializer"backtype.storm.serialization.types.ListDelegateSerializer", "topology.disruptor.wait.strategy"com.lmax.disruptor.BlockingWaitStrategy", "topology.multilang.serializer"backtype.storm.multilang.JsonSerializer", "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, "topology.worker.receiver.thread.count" 1, "storm.thrift.transport"backtype.storm.security.auth.SimpleTransportPlugin", "topology.state.synchronization.timeout.secs" 60, "supervisor.worker.timeout.secs" 30, "nimbus.file.copy.expiration.secs" 8000, "storm.messaging.transport"backtype.storm.messaging.netty.Context" "logviewer.appender.name"A1", "storm.messaging.netty.max_wait_ms" 1000, "drpc.request.timeout.secs" 1000, "storm.local.mode.zmq" false, "ui.port" 8080, "nimbus.childopts"- Xmx1024m", "storm.cluster.mode"local", "topology.max.task.parallelism" nil, "storm.messaging.netty.transfer.batch.size" 262144, "topology.classpath" nil}

4791 [Thread-6] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry-The baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [5]

4792 [Thread-6] INFO org.apache.storm.curator.framework.imps.CuratorFrameworkImpl-Starting

4792 [Thread-6] INFO org.apache.storm.zookeeper.ZooKeeper-Initiating client connection, connectString=localhost:2000 sessionTimeout=20000 watcher=org.apache.storm.curator.ConnectionState@c4fedd

4794 [Thread-6-SendThread (127.0.0.1 Thread-6-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 127.0.0.1 Universe 2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

4794 [Thread-6-SendThread (127.0.0.1 Thread-6-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Socket connection established to 127.0.0.1 Univer 2000, initiating session

4794 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-Accepted socket connection from / 127.0.0.1 purl 52222

4794 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Client attempting to establish new session at / 127.0.0.1 purl 52222

4867 [SyncThread:0] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Established session 0x1549474265a000a with negotiated timeout 20000 for client / 127.0.0.1 purl 52222

4867 [Thread-6-SendThread (127.0.0.1 Session establishment complete on server 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Session establishment complete on server 127.0.0.1 Unix 2000, sessionid = 0x1549474265a000a, negotiated timeout = 20000

4867 [Thread-6-EventThread] INFO org.apache.storm.curator.framework.state.ConnectionStateManager-State change: CONNECTED

4868 [Thread-6-EventThread] INFO backtype.storm.zookeeper-Zookeeper state update:: connected:none

4870 [ProcessThread (sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor-Processed session termination for sessionid: 0x1549474265a000a

4920 [Thread-6] INFO org.apache.storm.zookeeper.ZooKeeper-Session: 0x1549474265a000a closed

4920 [Thread-6-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn-EventThread shut down

4920 [Thread-6] INFO backtype.storm.utils.StormBoundedExponentialBackoffRetry-The baseSleepTimeMs [1000] the maxSleepTimeMs [30000] the maxRetries [5]

4921 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] WARN org.apache.storm.zookeeper.server.NIOServerCnxn-caught end of stream exception

Org.apache.storm.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x1549474265a000a, likely client has closed socket

At org.apache.storm.zookeeper.server.NIOServerCnxn.doIO (NIOServerCnxn.java:228) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.server.NIOServerCnxnFactory.run (NIOServerCnxnFactory.java:208) [storm-core-0.9.3.jar:0.9.3]

At java.lang.Thread.run (Thread.java:619) [na:1.6.0_13]

4921 [Thread-6] INFO org.apache.storm.curator.framework.imps.CuratorFrameworkImpl-Starting

4921 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxn-Closed socket connection for client / 127.0.0.1 Closed socket connection for client 52222 which had sessionid 0x1549474265a000a

4921 [Thread-6] INFO org.apache.storm.zookeeper.ZooKeeper-Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.curator.ConnectionState@160c21a

4923 [Thread-6-SendThread] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 0VOV 0VOUL2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 0VOVO VOULO VOULO VOUL0VOUL0VOUL0VOULO 0VOUL0VOULO 0Vl0VULlG00VlGUL2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

4923 [Thread-6-SendThread (0 Unable to open socket to 0, 0) 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,

4924 [Thread-6-SendThread (0 Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect)]

Java.net.SocketException: Address family not supported by protocol family: connect

At sun.nio.ch.Net.connect (Native Method) ~ [na:1.6.0_13]

At sun.nio.ch.SocketChannelImpl.connect (SocketChannelImpl.java:507) ~ [na:1.6.0_13]

At org.apache.storm.zookeeper.ClientCnxnSocketNIO.registerAndConnect (ClientCnxnSocketNIO.java:277) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxnSocketNIO.connect (ClientCnxnSocketNIO.java:287) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxn$SendThread.startConnect (ClientCnxn.java:967) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxn$SendThread.run (ClientCnxn.java:1003) ~ [storm-core-0.9.3.jar:0.9.3]

4962 [main] INFO backtype.storm.daemon.nimbus-Shutting down master

4965 [ProcessThread (sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor-Processed session termination for sessionid: 0x1549474265a0001

5024 [Thread-6-SendThread (127.0.0.1 Thread-6-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 127.0.0.1 Universe 2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

5025 [Thread-6-SendThread (127.0.0.1 Thread-6-SendThread 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Socket connection established to 127.0.0.1 Univer 2000, initiating session

5025 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-Accepted socket connection from / 127.0.0.1 purl 52225

5026 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Client attempting to establish new session at / 127.0.0.1 purl 52225

5036 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Session: 0x1549474265a0001 closed

5037 [main] INFO backtype.storm.daemon.nimbus-Shut down master

5037 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] WARN org.apache.storm.zookeeper.server.NIOServerCnxn-caught end of stream exception

Org.apache.storm.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client sessionid 0x1549474265a0001, likely client has closed socket

At org.apache.storm.zookeeper.server.NIOServerCnxn.doIO (NIOServerCnxn.java:228) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.server.NIOServerCnxnFactory.run (NIOServerCnxnFactory.java:208) [storm-core-0.9.3.jar:0.9.3]

At java.lang.Thread.run (Thread.java:619) [na:1.6.0_13]

5037 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxn-Closed socket connection for client / 127.0.0.1 Closed socket connection for client 52194 which had sessionid 0x1549474265a0001

5037 [main-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn-EventThread shut down

5037 [ProcessThread (sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor-Processed session termination for sessionid: 0x1549474265a0003

5117 [SyncThread:0] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-Established session 0x1549474265a000b with negotiated timeout 20000 for client / 127.0.0.1 purl 52225

5117 [Thread-6-SendThread (127.0.0.1 Session establishment complete on server 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Session establishment complete on server 127.0.0.1 Unix 2000, sessionid = 0x1549474265a000b, negotiated timeout = 20000

5117 [Thread-6-EventThread] INFO org.apache.storm.curator.framework.state.ConnectionStateManager-State change: CONNECTED

5162 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Session: 0x1549474265a0003 closed

5162 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxn-Closed socket connection for client / 127.0.0.1 Closed socket connection for client 52200 which had sessionid 0x1549474265a0003

5162 [main-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn-EventThread shut down

5163 [ProcessThread (sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor-Processed session termination for sessionid: 0x1549474265a0005

5195 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxn-Closed socket connection for client / 127.0.0.1 Closed socket connection for client 52206 which had sessionid 0x1549474265a0005

5195 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Session: 0x1549474265a0005 closed

5195 [main-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn-EventThread shut down

5196 [main] INFO backtype.storm.daemon.supervisor-Shutting down supervisor 2da9a25c-7c2e-40ce-bce4-e5995a3e15c7

5197 [Thread-3] INFO backtype.storm.event-Event manager interrupted

5198 [Thread-4] INFO backtype.storm.event-Event manager interrupted

5199 [ProcessThread (sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor-Processed session termination for sessionid: 0x1549474265a0007

5199 [Thread-6] INFO backtype.storm.daemon.worker-Reading Assignments.

5237 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxn-Closed socket connection for client / 127.0.0.1 Closed socket connection for client 52212 which had sessionid 0x1549474265a0007

5237 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Session: 0x1549474265a0007 closed

5238 [main-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn-EventThread shut down

5238 [main] INFO backtype.storm.daemon.supervisor-Shutting down 52ca5c90-e7f4-471e-ad8b-b66fa7f3569b:c64355a8-46e2-4880-80f0-0c3cb41eba52

5243 [main] INFO backtype.storm.daemon.supervisor-Shut down 52ca5c90-e7f4-471e-ad8b-b66fa7f3569b:c64355a8-46e2-4880-80f0-0c3cb41eba52

5243 [main] INFO backtype.storm.daemon.supervisor-Shutting down supervisor 52ca5c90-e7f4-471e-ad8b-b66fa7f3569b

5243 [Thread-5] INFO backtype.storm.event-Event manager interrupted

5277 [Thread-6] INFO backtype.storm.event-Event manager interrupted

5278 [ProcessThread (sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor-Processed session termination for sessionid: 0x1549474265a0009

5320 [main] INFO org.apache.storm.zookeeper.ZooKeeper-Session: 0x1549474265a0009 closed

5320 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxn-Closed socket connection for client / 127.0.0.1 Closed socket connection for client 52218 which had sessionid 0x1549474265a0009

5320 [main-EventThread] INFO org.apache.storm.zookeeper.ClientCnxn-EventThread shut down

5320 [main] INFO backtype.storm.testing-Shutting down in process zookeeper

5320 [main] INFO org.apache.storm.zookeeper.server.NIOServerCnxn-Closed socket connection for client / 127.0.0.1 Closed socket connection for client 52225 which had sessionid 0x1549474265a000b

5320 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO org.apache.storm.zookeeper.server.NIOServerCnxnFactory-NIOServerCnxn factory exited run method

5321 [Thread-6-SendThread (127.0.0.1 Unable to read additional data from server sessionid 0x1549474265a000b 2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Unable to read additional data from server sessionid 0x1549474265a000b, likely server has closed socket, closing socket connection and attempting reconnect

5321 [main] INFO org.apache.storm.zookeeper.server.ZooKeeperServer-shutting down

5321 [main] INFO org.apache.storm.zookeeper.server.SessionTrackerImpl-Shutting down

5321 [main] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor-Shutting down

5321 [main] INFO org.apache.storm.zookeeper.server.SyncRequestProcessor-Shutting down

5321 [SyncThread:0] INFO org.apache.storm.zookeeper.server.SyncRequestProcessor-SyncRequestProcessor exited!

5321 [ProcessThread (sid:0 cport:-1):] INFO org.apache.storm.zookeeper.server.PrepRequestProcessor-PrepRequestProcessor exited loop!

5321 [main] INFO org.apache.storm.zookeeper.server.FinalRequestProcessor-shutdown of request processor complete

5321 [main] INFO backtype.storm.testing-Done shutting down in process zookeeper

5321 [main] INFO backtype.storm.testing-Deleting temporary path C:\ Users\ ADMINI~1\ AppData\ Local\ Temp\ a49e6cc7-163f-483c-acc5-b7ef66811e93

5329 [main] INFO backtype.storm.testing-Deleting temporary path C:\ Users\ ADMINI~1\ AppData\ Local\ Temp\ dfd81caa-cc57-42c9-ba21-11ccac776aff

5330 [main] INFO backtype.storm.testing-Unable to delete file: C:\ Users\ ADMINI~1\ AppData\ Local\ Temp\ dfd81caa-cc57-42c9-ba21-11ccac776aff\ version-2\ log.1

5330 [main] INFO backtype.storm.testing-Deleting temporary path C:\ Users\ ADMINI~1\ AppData\ Local\ Temp\ 43b32479-d481-4c24-8688-3eada2523a5e

5366 [main] INFO backtype.storm.testing-Deleting temporary path C:\ Users\ ADMINI~1\ AppData\ Local\ Temp\ 4bba3e0c-c4f4-4a90-b520-51168b660791

5421 [Thread-6-EventThread] INFO org.apache.storm.curator.framework.state.ConnectionStateManager-State change: SUSPENDED

5424 [Thread-6-EventThread] WARN backtype.storm.cluster-Received event: disconnected::none: with disconnected Zookeeper.

5955 [Thread-6-SendThread] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 0VOV 0VOUL2000)] INFO org.apache.storm.zookeeper.ClientCnxn-Opening socket connection to server 0VOVO VOULO VOULO VOUL0VOUL0VOUL0VOULO 0VOUL0VOULO 0Vl0VULlG00VlGUL2000. Will not attempt to authenticate using SASL (java.lang.SecurityException: unable to locate login configuration)

5956 [Thread-6-SendThread (0 Unable to open socket to 0, 0) 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,

5956 [Thread-6-SendThread (0 Session 0x1549474265a000b for server null, unexpected error, closing socket connection and attempting reconnect)]

Java.net.SocketException: Address family not supported by protocol family: connect

At sun.nio.ch.Net.connect (Native Method) ~ [na:1.6.0_13]

At sun.nio.ch.SocketChannelImpl.connect (SocketChannelImpl.java:507) ~ [na:1.6.0_13]

At org.apache.storm.zookeeper.ClientCnxnSocketNIO.registerAndConnect (ClientCnxnSocketNIO.java:277) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxnSocketNIO.connect (ClientCnxnSocketNIO.java:287) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxn$SendThread.startConnect (ClientCnxn.java:967) ~ [storm-core-0.9.3.jar:0.9.3]

At org.apache.storm.zookeeper.ClientCnxn$SendThread.run (ClientCnxn.java:1003) ~ [storm-core-0.9.3.jar:0.9.3]

7042 [SessionTracker] INFO org.apache.storm.zookeeper.server.SessionTrackerImpl-SessionTrackerImpl exited loop!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.