-
-
Save sethgrid/c64eb01deec37f5b95d1 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| $ pwd | |
| /Users/sethammons/playground/storm/storm/storm/examples/storm-starter | |
| 11:10:41 sethammons@Seth-Ammons-6:~/playground/storm/storm/storm/examples/storm-starter (git:master:7f4aa5d) | |
| $ mvn compile exec:java -Dstorm.topology=storm.starter.ExclamationTopology | |
| [INFO] Scanning for projects... | |
| [WARNING] | |
| [WARNING] Some problems were encountered while building the effective model for org.apache.storm:storm-starter:jar:0.11.0-SNAPSHOT | |
| [WARNING] 'parent.relativePath' of POM org.apache.storm:storm:0.11.0-SNAPSHOT (/Users/sethammons/playground/storm/storm/storm/pom.xml) points at org.apache.storm:storm instead of org.apache:apache, please verify your project structure @ org.apache.storm:storm:0.11.0-SNAPSHOT, /Users/sethammons/playground/storm/storm/storm/pom.xml, line 21, column 13 | |
| [WARNING] | |
| [WARNING] It is highly recommended to fix these problems because they threaten the stability of your build. | |
| [WARNING] | |
| [WARNING] For this reason, future Maven versions might no longer support building such malformed projects. | |
| [WARNING] | |
| [INFO] | |
| [INFO] ------------------------------------------------------------------------ | |
| [INFO] Building storm-starter 0.11.0-SNAPSHOT | |
| [INFO] ------------------------------------------------------------------------ | |
| [INFO] | |
| [INFO] --- maven-remote-resources-plugin:1.2.1:process (default) @ storm-starter --- | |
| [INFO] | |
| [INFO] --- maven-resources-plugin:2.5:resources (default-resources) @ storm-starter --- | |
| [debug] execute contextualize | |
| [INFO] Using 'UTF-8' encoding to copy filtered resources. | |
| [INFO] Copying 5 resources | |
| [INFO] Copying 3 resources | |
| [INFO] | |
| [INFO] --- maven-compiler-plugin:3.1:compile (default-compile) @ storm-starter --- | |
| [INFO] Nothing to compile - all classes are up to date | |
| [INFO] | |
| [INFO] --- clojure-maven-plugin:1.7.1:compile (compile) @ storm-starter --- | |
| [INFO] | |
| [INFO] >>> exec-maven-plugin:1.2.1:java (default-cli) > validate @ storm-starter >>> | |
| [INFO] | |
| [INFO] <<< exec-maven-plugin:1.2.1:java (default-cli) < validate @ storm-starter <<< | |
| [INFO] | |
| [INFO] --- exec-maven-plugin:1.2.1:java (default-cli) @ storm-starter --- | |
| 7204 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:zookeeper.version=3.4.6-1569965, built on 02/20/2014 09:09 GMT | |
| 7205 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:host.name=192.168.1.9 | |
| 7205 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:java.version=1.8.0_60 | |
| 7205 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:java.vendor=Oracle Corporation | |
| 7205 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:java.home=/Library/Java/JavaVirtualMachines/jdk1.8.0_60.jdk/Contents/Home/jre | |
| 7205 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:java.class.path=/usr/local/Cellar/maven/3.3.3/libexec/boot/plexus-classworlds-2.5.2.jar | |
| 7205 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:java.library.path=/Users/sethammons/Library/Java/Extensions:/Library/Java/Extensions:/Network/Library/Java/Extensions:/System/Library/Java/Extensions:/usr/lib/java:. | |
| 7205 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:java.io.tmpdir=/var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T/ | |
| 7205 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:java.compiler=<NA> | |
| 7205 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:os.name=Mac OS X | |
| 7205 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:os.arch=x86_64 | |
| 7205 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:os.version=10.11.2 | |
| 7205 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:user.name=sethammons | |
| 7205 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:user.home=/Users/sethammons | |
| 7206 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Server environment:user.dir=/Users/sethammons/playground/storm/storm/storm/examples/storm-starter | |
| 7218 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Created server with tickTime 2000 minSessionTimeout 4000 maxSessionTimeout 40000 datadir /var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T/3c34b54e-156e-4516-bb6e-b9281b02b98d/version-2 snapdir /var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T/3c34b54e-156e-4516-bb6e-b9281b02b98d/version-2 | |
| 7235 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - binding to port 0.0.0.0/0.0.0.0:2000 | |
| 7240 [storm.starter.ExclamationTopology.main()] INFO b.s.zookeeper - Starting inprocess zookeeper at port 2000 and dir /var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T//3c34b54e-156e-4516-bb6e-b9281b02b98d | |
| 7307 [storm.starter.ExclamationTopology.main()] INFO b.s.d.nimbus - Starting Nimbus with conf {"topology.builtin.metrics.bucket.size.secs" 60, "nimbus.childopts" "-Xmx1024m", "ui.filter.params" nil, "storm.cluster.mode" "local", "storm.messaging.netty.client_worker_threads" 1, "logviewer.max.per.worker.logs.size.mb" 2048, "supervisor.run.worker.as.user" false, "topology.max.task.parallelism" nil, "topology.priority" 29, "zmq.threads" 1, "storm.group.mapping.service" "backtype.storm.security.auth.ShellBasedGroupsMapping", "transactional.zookeeper.root" "/transactional", "topology.sleep.spout.wait.strategy.time.ms" 1, "scheduler.display.resource" false, "topology.max.replication.wait.time.sec" 60, "drpc.invocations.port" 3773, "supervisor.localizer.cache.target.size.mb" 10240, "topology.multilang.serializer" "backtype.storm.multilang.JsonSerializer", "storm.messaging.netty.server_worker_threads" 1, "nimbus.blobstore.class" "backtype.storm.blobstore.LocalFsBlobStore", "resource.aware.scheduler.eviction.strategy" "backtype.storm.scheduler.resource.strategies.eviction.DefaultEvictionStrategy", "topology.max.error.report.per.interval" 5, "storm.thrift.transport" "backtype.storm.security.auth.SimpleTransportPlugin", "zmq.hwm" 0, "storm.group.mapping.service.params" nil, "worker.profiler.enabled" true, "storm.principal.tolocal" "backtype.storm.security.auth.DefaultPrincipalToLocal", "supervisor.worker.shutdown.sleep.secs" 1, "pacemaker.host" "localhost", "storm.zookeeper.retry.times" 5, "ui.actions.enabled" true, "zmq.linger.millis" 0, "supervisor.enable" true, "topology.stats.sample.rate" 0.05, "storm.messaging.netty.min_wait_ms" 100, "worker.log.level.reset.poll.secs" 30, "storm.zookeeper.port" 2000, "supervisor.heartbeat.frequency.secs" 5, "topology.enable.message.timeouts" true, "supervisor.cpu.capacity" 400.0, "drpc.worker.threads" 64, "supervisor.blobstore.download.thread.count" 5, "drpc.queue.size" 128, "topology.backpressure.enable" true, "supervisor.blobstore.class" "backtype.storm.blobstore.NimbusBlobStore", "storm.blobstore.inputstream.buffer.size.bytes" 65536, "topology.shellbolt.max.pending" 100, "drpc.https.keystore.password" "", "nimbus.code.sync.freq.secs" 120, "logviewer.port" 8000, "topology.scheduler.strategy" "backtype.storm.scheduler.resource.strategies.scheduling.DefaultResourceAwareStrategy", "topology.executor.send.buffer.size" 1024, "resource.aware.scheduler.priority.strategy" "backtype.storm.scheduler.resource.strategies.priority.DefaultSchedulingPriorityStrategy", "pacemaker.auth.method" "NONE", "topology.worker.logwriter.childopts" "-Xmx64m", "topology.spout.wait.strategy" "backtype.storm.spout.SleepSpoutWaitStrategy", "ui.host" "0.0.0.0", "storm.nimbus.retry.interval.millis" 2000, "nimbus.inbox.jar.expiration.secs" 3600, "dev.zookeeper.path" "/tmp/dev-storm-zookeeper", "topology.acker.executors" nil, "topology.fall.back.on.java.serialization" true, "topology.eventlogger.executors" nil, "supervisor.localizer.cleanup.interval.ms" 600000, "storm.zookeeper.servers" ["localhost"], "nimbus.thrift.threads" 64, "logviewer.cleanup.age.mins" 10080, "topology.worker.childopts" nil, "topology.classpath" nil, "supervisor.monitor.frequency.secs" 3, "nimbus.credential.renewers.freq.secs" 600, "topology.skip.missing.kryo.registrations" true, "drpc.authorizer.acl.filename" "drpc-auth-acl.yaml", "pacemaker.kerberos.users" [], "storm.group.mapping.service.cache.duration.secs" 120, "topology.testing.always.try.serialize" false, "nimbus.monitor.freq.secs" 10, "storm.health.check.timeout.ms" 5000, "supervisor.supervisors" [], "topology.tasks" nil, "topology.bolts.outgoing.overflow.buffer.enable" false, "storm.messaging.netty.socket.backlog" 500, "topology.workers" 1, "pacemaker.base.threads" 10, "storm.local.dir" "/var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T//15ce2e75-6fc1-48cd-9e8a-1e881a339206", "topology.disable.loadaware" false, "worker.childopts" "-Xmx%HEAP-MEM%m -XX:+PrintGCDetails -Xloggc:artifacts/gc.log -XX:+PrintGCDateStamps -XX:+PrintGCTimeStamps -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=10 -XX:GCLogFileSize=1M -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=artifacts/heapdump", "storm.auth.simple-white-list.users" [], "topology.disruptor.batch.timeout.millis" 1, "topology.message.timeout.secs" 30, "topology.state.synchronization.timeout.secs" 60, "topology.tuple.serializer" "backtype.storm.serialization.types.ListDelegateSerializer", "supervisor.supervisors.commands" [], "nimbus.blobstore.expiration.secs" 600, "logviewer.childopts" "-Xmx128m", "topology.environment" nil, "topology.debug" false, "topology.disruptor.batch.size" 100, "storm.messaging.netty.max_retries" 300, "ui.childopts" "-Xmx768m", "storm.network.topography.plugin" "backtype.storm.networktopography.DefaultRackDNSToSwitchMapping", "storm.zookeeper.session.timeout" 20000, "drpc.childopts" "-Xmx768m", "drpc.http.creds.plugin" "backtype.storm.security.auth.DefaultHttpCredentialsPlugin", "storm.zookeeper.connection.timeout" 15000, "storm.zookeeper.auth.user" nil, "storm.meta.serialization.delegate" "backtype.storm.serialization.GzipThriftSerializationDelegate", "topology.max.spout.pending" nil, "storm.codedistributor.class" "backtype.storm.codedistributor.LocalFileSystemCodeDistributor", "nimbus.supervisor.timeout.secs" 60, "nimbus.task.timeout.secs" 30, "drpc.port" 3772, "pacemaker.max.threads" 50, "storm.zookeeper.retry.intervalceiling.millis" 30000, "nimbus.thrift.port" 6627, "storm.auth.simple-acl.admins" [], "topology.component.cpu.pcore.percent" 10.0, "supervisor.memory.capacity.mb" 3072.0, "storm.nimbus.retry.times" 5, "supervisor.worker.start.timeout.secs" 120, "storm.zookeeper.retry.interval" 1000, "logs.users" nil, "worker.profiler.command" "flight.bash", "transactional.zookeeper.port" nil, "drpc.max_buffer_size" 1048576, "pacemaker.thread.timeout" 10, "task.credentials.poll.secs" 30, "blobstore.superuser" "sethammons", "drpc.https.keystore.type" "JKS", "topology.worker.receiver.thread.count" 1, "supervisor.slots.ports" [6700 6701 6702 6703], "topology.transfer.buffer.size" 1024, "storm.health.check.dir" "healthchecks", "topology.worker.shared.thread.pool.size" 4, "drpc.authorizer.acl.strict" false, "nimbus.file.copy.expiration.secs" 600, "worker.profiler.childopts" "-XX:+UnlockCommercialFeatures -XX:+FlightRecorder", "topology.executor.receive.buffer.size" 1024, "backpressure.disruptor.low.watermark" 0.4, "nimbus.task.launch.secs" 120, "storm.local.mode.zmq" false, "storm.messaging.netty.buffer_size" 5242880, "storm.cluster.state.store" "backtype.storm.cluster_state.zookeeper_state_factory", "worker.heartbeat.frequency.secs" 1, "storm.log4j2.conf.dir" "log4j2", "ui.http.creds.plugin" "backtype.storm.security.auth.DefaultHttpCredentialsPlugin", "storm.zookeeper.root" "/storm", "topology.tick.tuple.freq.secs" nil, "drpc.https.port" -1, "storm.workers.artifacts.dir" "workers-artifacts", "supervisor.blobstore.download.max_retries" 3, "task.refresh.poll.secs" 10, "task.heartbeat.frequency.secs" 3, "pacemaker.port" 6699, "storm.messaging.netty.max_wait_ms" 1000, "nimbus.impersonation.authorizer" "backtype.storm.security.auth.authorizer.ImpersonationAuthorizer", "topology.component.resources.offheap.memory.mb" 0.0, "drpc.http.port" 3774, "topology.error.throttle.interval.secs" 10, "storm.messaging.transport" "backtype.storm.messaging.netty.Context", "storm.messaging.netty.authentication" false, "topology.component.resources.onheap.memory.mb" 128.0, "topology.kryo.factory" "backtype.storm.serialization.DefaultKryoFactory", "worker.gc.childopts" "", "nimbus.topology.validator" "backtype.storm.nimbus.DefaultTopologyValidator", "nimbus.seeds" ["localhost"], "nimbus.cleanup.inbox.freq.secs" 600, "storm.blobstore.replication.factor" 3, "worker.heap.memory.mb" 768, "logviewer.max.sum.worker.logs.size.mb" 4096, "pacemaker.childopts" "-Xmx1024m", "ui.users" nil, "transactional.zookeeper.servers" nil, "supervisor.worker.timeout.secs" 30, "storm.zookeeper.auth.password" nil, "client.blobstore.class" "backtype.storm.blobstore.NimbusBlobStore", "supervisor.childopts" "-Xmx256m", "topology.worker.max.heap.size.mb" 768.0, "backpressure.disruptor.high.watermark" 0.9, "ui.filter" nil, "ui.header.buffer.bytes" 4096, "topology.min.replication.count" 1, "topology.disruptor.wait.timeout.millis" 1000, "storm.nimbus.retry.intervalceiling.millis" 60000, "topology.trident.batch.emit.interval.millis" 50, "storm.auth.simple-acl.users" [], "drpc.invocations.threads" 64, "java.library.path" "/usr/local/lib:/opt/local/lib:/usr/lib", "ui.port" 8080, "storm.messaging.netty.transfer.batch.size" 262144, "logviewer.appender.name" "A1", "nimbus.thrift.max_buffer_size" 1048576, "storm.auth.simple-acl.users.commands" [], "drpc.request.timeout.secs" 600} | |
| 7308 [storm.starter.ExclamationTopology.main()] INFO b.s.d.nimbus - Using default scheduler | |
| 7363 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7367 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:zookeeper.version=3.4.6-1569965, built on 02/20/2014 09:09 GMT | |
| 7367 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:host.name=192.168.1.9 | |
| 7367 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:java.version=1.8.0_60 | |
| 7367 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:java.vendor=Oracle Corporation | |
| 7367 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:java.home=/Library/Java/JavaVirtualMachines/jdk1.8.0_60.jdk/Contents/Home/jre | |
| 7367 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:java.class.path=/usr/local/Cellar/maven/3.3.3/libexec/boot/plexus-classworlds-2.5.2.jar | |
| 7367 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:java.library.path=/Users/sethammons/Library/Java/Extensions:/Library/Java/Extensions:/Network/Library/Java/Extensions:/System/Library/Java/Extensions:/usr/lib/java:. | |
| 7367 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:java.io.tmpdir=/var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T/ | |
| 7367 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:java.compiler=<NA> | |
| 7368 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:os.name=Mac OS X | |
| 7368 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:os.arch=x86_64 | |
| 7368 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:os.version=10.11.2 | |
| 7368 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:user.name=sethammons | |
| 7368 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:user.home=/Users/sethammons | |
| 7368 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Client environment:user.dir=/Users/sethammons/playground/storm/storm/storm/examples/storm-starter | |
| 7368 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000 sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@1d5e53d2 | |
| 7387 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7393 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/127.0.0.1:2000, initiating session | |
| 7393 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /127.0.0.1:56324 | |
| 7398 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /127.0.0.1:56324 | |
| 7401 [SyncThread:0] INFO o.a.s.s.o.a.z.s.p.FileTxnLog - Creating new log file: log.1 | |
| 7401 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7401 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@463aba85 | |
| 7404 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7405 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/0:0:0:0:0:0:0:1:2000, initiating session | |
| 7405 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /0:0:0:0:0:0:0:1:56325 | |
| 7406 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /0:0:0:0:0:0:0:1:56325 | |
| 7408 [storm.starter.ExclamationTopology.main()] INFO b.s.b.FileBlobStoreImpl - Creating new blob store based in /var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T/15ce2e75-6fc1-48cd-9e8a-1e881a339206/blobs | |
| 7417 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2000, sessionid = 0x151c5f3c4700000, negotiated timeout = 20000 | |
| 7417 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c4700000 with negotiated timeout 20000 for client /127.0.0.1:56324 | |
| 7424 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c4700001 with negotiated timeout 20000 for client /0:0:0:0:0:0:0:1:56325 | |
| 7425 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/0:0:0:0:0:0:0:1:2000, sessionid = 0x151c5f3c4700001, negotiated timeout = 20000 | |
| 7427 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7427 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7429 [storm.starter.ExclamationTopology.main()-EventThread] INFO b.s.zookeeper - Zookeeper state update: :connected:none | |
| 7440 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7441 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000 sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@798ddbdd | |
| 7443 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7444 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/127.0.0.1:2000, initiating session | |
| 7444 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /127.0.0.1:56326 | |
| 7445 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /127.0.0.1:56326 | |
| 7449 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c4700002 with negotiated timeout 20000 for client /127.0.0.1:56326 | |
| 7449 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2000, sessionid = 0x151c5f3c4700002, negotiated timeout = 20000 | |
| 7449 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7450 [storm.starter.ExclamationTopology.main()-EventThread] INFO b.s.zookeeper - Zookeeper state update: :connected:none | |
| 7475 [ProcessThread(sid:0 cport:-1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Processed session termination for sessionid: 0x151c5f3c4700002 | |
| 7476 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Session: 0x151c5f3c4700002 closed | |
| 7476 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shut down | |
| 7477 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - Closed socket connection for client /127.0.0.1:56326 which had sessionid 0x151c5f3c4700002 | |
| 7478 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7478 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@2749e9e8 | |
| 7480 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7480 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /127.0.0.1:56327 | |
| 7480 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/127.0.0.1:2000, initiating session | |
| 7480 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /127.0.0.1:56327 | |
| 7481 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c4700003 with negotiated timeout 20000 for client /127.0.0.1:56327 | |
| 7481 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2000, sessionid = 0x151c5f3c4700003, negotiated timeout = 20000 | |
| 7481 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7521 [storm.starter.ExclamationTopology.main()] INFO b.s.zookeeper - Queued up for leader lock. | |
| 7527 [ProcessThread(sid:0 cport:-1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Got user-level KeeperException when processing sessionid:0x151c5f3c4700000 type:create cxid:0x1 zxid:0x10 txntype:-1 reqpath:n/a Error Path:/storm/leader-lock Error:KeeperErrorCode = NoNode for /storm/leader-lock | |
| 7531 [Curator-Framework-0] WARN o.a.s.s.o.a.c.u.ZKPaths - The version of ZooKeeper being used doesn't support Container nodes. CreateMode.PERSISTENT will be used instead. | |
| 7541 [storm.starter.ExclamationTopology.main()-EventThread] INFO b.s.zookeeper - 192.168.1.9 gained leadership | |
| 7568 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7569 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000 sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@61069e8b | |
| 7570 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7570 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/0:0:0:0:0:0:0:1:2000, initiating session | |
| 7570 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /0:0:0:0:0:0:0:1:56328 | |
| 7571 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /0:0:0:0:0:0:0:1:56328 | |
| 7571 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c4700004 with negotiated timeout 20000 for client /0:0:0:0:0:0:0:1:56328 | |
| 7571 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/0:0:0:0:0:0:0:1:2000, sessionid = 0x151c5f3c4700004, negotiated timeout = 20000 | |
| 7572 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7572 [storm.starter.ExclamationTopology.main()-EventThread] INFO b.s.zookeeper - Zookeeper state update: :connected:none | |
| 7573 [ProcessThread(sid:0 cport:-1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Processed session termination for sessionid: 0x151c5f3c4700004 | |
| 7573 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Session: 0x151c5f3c4700004 closed | |
| 7573 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shut down | |
| 7574 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - Closed socket connection for client /0:0:0:0:0:0:0:1:56328 which had sessionid 0x151c5f3c4700004 | |
| 7574 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7574 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@2678b327 | |
| 7576 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7576 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7576 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/0:0:0:0:0:0:0:1:2000, initiating session | |
| 7576 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000 sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@3db22bb | |
| 7576 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /0:0:0:0:0:0:0:1:56329 | |
| 7576 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /0:0:0:0:0:0:0:1:56329 | |
| 7577 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c4700005 with negotiated timeout 20000 for client /0:0:0:0:0:0:0:1:56329 | |
| 7578 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7578 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/0:0:0:0:0:0:0:1:2000, sessionid = 0x151c5f3c4700005, negotiated timeout = 20000 | |
| 7578 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7578 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/127.0.0.1:2000, initiating session | |
| 7578 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /127.0.0.1:56330 | |
| 7584 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /127.0.0.1:56330 | |
| 7584 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c4700006 with negotiated timeout 20000 for client /127.0.0.1:56330 | |
| 7584 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2000, sessionid = 0x151c5f3c4700006, negotiated timeout = 20000 | |
| 7585 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7585 [storm.starter.ExclamationTopology.main()-EventThread] INFO b.s.zookeeper - Zookeeper state update: :connected:none | |
| 7586 [ProcessThread(sid:0 cport:-1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Processed session termination for sessionid: 0x151c5f3c4700006 | |
| 7586 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shut down | |
| 7586 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Session: 0x151c5f3c4700006 closed | |
| 7587 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - Closed socket connection for client /127.0.0.1:56330 which had sessionid 0x151c5f3c4700006 | |
| 7587 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7588 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@71d8cebb | |
| 7589 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7589 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/0:0:0:0:0:0:0:1:2000, initiating session | |
| 7589 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /0:0:0:0:0:0:0:1:56331 | |
| 7589 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /0:0:0:0:0:0:0:1:56331 | |
| 7590 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c4700007 with negotiated timeout 20000 for client /0:0:0:0:0:0:0:1:56331 | |
| 7590 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/0:0:0:0:0:0:0:1:2000, sessionid = 0x151c5f3c4700007, negotiated timeout = 20000 | |
| 7590 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7604 [storm.starter.ExclamationTopology.main()] INFO b.s.d.supervisor - Starting Supervisor with conf {"topology.builtin.metrics.bucket.size.secs" 60, "nimbus.childopts" "-Xmx1024m", "ui.filter.params" nil, "storm.cluster.mode" "local", "storm.messaging.netty.client_worker_threads" 1, "logviewer.max.per.worker.logs.size.mb" 2048, "supervisor.run.worker.as.user" false, "topology.max.task.parallelism" nil, "topology.priority" 29, "zmq.threads" 1, "storm.group.mapping.service" "backtype.storm.security.auth.ShellBasedGroupsMapping", "transactional.zookeeper.root" "/transactional", "topology.sleep.spout.wait.strategy.time.ms" 1, "scheduler.display.resource" false, "topology.max.replication.wait.time.sec" 60, "drpc.invocations.port" 3773, "supervisor.localizer.cache.target.size.mb" 10240, "topology.multilang.serializer" "backtype.storm.multilang.JsonSerializer", "storm.messaging.netty.server_worker_threads" 1, "nimbus.blobstore.class" "backtype.storm.blobstore.LocalFsBlobStore", "resource.aware.scheduler.eviction.strategy" "backtype.storm.scheduler.resource.strategies.eviction.DefaultEvictionStrategy", "topology.max.error.report.per.interval" 5, "storm.thrift.transport" "backtype.storm.security.auth.SimpleTransportPlugin", "zmq.hwm" 0, "storm.group.mapping.service.params" nil, "worker.profiler.enabled" true, "storm.principal.tolocal" "backtype.storm.security.auth.DefaultPrincipalToLocal", "supervisor.worker.shutdown.sleep.secs" 1, "pacemaker.host" "localhost", "storm.zookeeper.retry.times" 5, "ui.actions.enabled" true, "zmq.linger.millis" 0, "supervisor.enable" true, "topology.stats.sample.rate" 0.05, "storm.messaging.netty.min_wait_ms" 100, "worker.log.level.reset.poll.secs" 30, "storm.zookeeper.port" 2000, "supervisor.heartbeat.frequency.secs" 5, "topology.enable.message.timeouts" true, "supervisor.cpu.capacity" 400.0, "drpc.worker.threads" 64, "supervisor.blobstore.download.thread.count" 5, "drpc.queue.size" 128, "topology.backpressure.enable" true, "supervisor.blobstore.class" "backtype.storm.blobstore.NimbusBlobStore", "storm.blobstore.inputstream.buffer.size.bytes" 65536, "topology.shellbolt.max.pending" 100, "drpc.https.keystore.password" "", "nimbus.code.sync.freq.secs" 120, "logviewer.port" 8000, "topology.scheduler.strategy" "backtype.storm.scheduler.resource.strategies.scheduling.DefaultResourceAwareStrategy", "topology.executor.send.buffer.size" 1024, "resource.aware.scheduler.priority.strategy" "backtype.storm.scheduler.resource.strategies.priority.DefaultSchedulingPriorityStrategy", "pacemaker.auth.method" "NONE", "topology.worker.logwriter.childopts" "-Xmx64m", "topology.spout.wait.strategy" "backtype.storm.spout.SleepSpoutWaitStrategy", "ui.host" "0.0.0.0", "storm.nimbus.retry.interval.millis" 2000, "nimbus.inbox.jar.expiration.secs" 3600, "dev.zookeeper.path" "/tmp/dev-storm-zookeeper", "topology.acker.executors" nil, "topology.fall.back.on.java.serialization" true, "topology.eventlogger.executors" nil, "supervisor.localizer.cleanup.interval.ms" 600000, "storm.zookeeper.servers" ["localhost"], "nimbus.thrift.threads" 64, "logviewer.cleanup.age.mins" 10080, "topology.worker.childopts" nil, "topology.classpath" nil, "supervisor.monitor.frequency.secs" 3, "nimbus.credential.renewers.freq.secs" 600, "topology.skip.missing.kryo.registrations" true, "drpc.authorizer.acl.filename" "drpc-auth-acl.yaml", "pacemaker.kerberos.users" [], "storm.group.mapping.service.cache.duration.secs" 120, "topology.testing.always.try.serialize" false, "nimbus.monitor.freq.secs" 10, "storm.health.check.timeout.ms" 5000, "supervisor.supervisors" [], "topology.tasks" nil, "topology.bolts.outgoing.overflow.buffer.enable" false, "storm.messaging.netty.socket.backlog" 500, "topology.workers" 1, "pacemaker.base.threads" 10, "storm.local.dir" "/var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T//4241d14c-c1e1-4c1e-8860-d58d35b9ac46", "topology.disable.loadaware" false, "worker.childopts" "-Xmx%HEAP-MEM%m -XX:+PrintGCDetails -Xloggc:artifacts/gc.log -XX:+PrintGCDateStamps -XX:+PrintGCTimeStamps -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=10 -XX:GCLogFileSize=1M -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=artifacts/heapdump", "storm.auth.simple-white-list.users" [], "topology.disruptor.batch.timeout.millis" 1, "topology.message.timeout.secs" 30, "topology.state.synchronization.timeout.secs" 60, "topology.tuple.serializer" "backtype.storm.serialization.types.ListDelegateSerializer", "supervisor.supervisors.commands" [], "nimbus.blobstore.expiration.secs" 600, "logviewer.childopts" "-Xmx128m", "topology.environment" nil, "topology.debug" false, "topology.disruptor.batch.size" 100, "storm.messaging.netty.max_retries" 300, "ui.childopts" "-Xmx768m", "storm.network.topography.plugin" "backtype.storm.networktopography.DefaultRackDNSToSwitchMapping", "storm.zookeeper.session.timeout" 20000, "drpc.childopts" "-Xmx768m", "drpc.http.creds.plugin" "backtype.storm.security.auth.DefaultHttpCredentialsPlugin", "storm.zookeeper.connection.timeout" 15000, "storm.zookeeper.auth.user" nil, "storm.meta.serialization.delegate" "backtype.storm.serialization.GzipThriftSerializationDelegate", "topology.max.spout.pending" nil, "storm.codedistributor.class" "backtype.storm.codedistributor.LocalFileSystemCodeDistributor", "nimbus.supervisor.timeout.secs" 60, "nimbus.task.timeout.secs" 30, "drpc.port" 3772, "pacemaker.max.threads" 50, "storm.zookeeper.retry.intervalceiling.millis" 30000, "nimbus.thrift.port" 6627, "storm.auth.simple-acl.admins" [], "topology.component.cpu.pcore.percent" 10.0, "supervisor.memory.capacity.mb" 3072.0, "storm.nimbus.retry.times" 5, "supervisor.worker.start.timeout.secs" 120, "storm.zookeeper.retry.interval" 1000, "logs.users" nil, "worker.profiler.command" "flight.bash", "transactional.zookeeper.port" nil, "drpc.max_buffer_size" 1048576, "pacemaker.thread.timeout" 10, "task.credentials.poll.secs" 30, "blobstore.superuser" "sethammons", "drpc.https.keystore.type" "JKS", "topology.worker.receiver.thread.count" 1, "supervisor.slots.ports" (1024 1025 1026), "topology.transfer.buffer.size" 1024, "storm.health.check.dir" "healthchecks", "topology.worker.shared.thread.pool.size" 4, "drpc.authorizer.acl.strict" false, "nimbus.file.copy.expiration.secs" 600, "worker.profiler.childopts" "-XX:+UnlockCommercialFeatures -XX:+FlightRecorder", "topology.executor.receive.buffer.size" 1024, "backpressure.disruptor.low.watermark" 0.4, "nimbus.task.launch.secs" 120, "storm.local.mode.zmq" false, "storm.messaging.netty.buffer_size" 5242880, "storm.cluster.state.store" "backtype.storm.cluster_state.zookeeper_state_factory", "worker.heartbeat.frequency.secs" 1, "storm.log4j2.conf.dir" "log4j2", "ui.http.creds.plugin" "backtype.storm.security.auth.DefaultHttpCredentialsPlugin", "storm.zookeeper.root" "/storm", "topology.tick.tuple.freq.secs" nil, "drpc.https.port" -1, "storm.workers.artifacts.dir" "workers-artifacts", "supervisor.blobstore.download.max_retries" 3, "task.refresh.poll.secs" 10, "task.heartbeat.frequency.secs" 3, "pacemaker.port" 6699, "storm.messaging.netty.max_wait_ms" 1000, "nimbus.impersonation.authorizer" "backtype.storm.security.auth.authorizer.ImpersonationAuthorizer", "topology.component.resources.offheap.memory.mb" 0.0, "drpc.http.port" 3774, "topology.error.throttle.interval.secs" 10, "storm.messaging.transport" "backtype.storm.messaging.netty.Context", "storm.messaging.netty.authentication" false, "topology.component.resources.onheap.memory.mb" 128.0, "topology.kryo.factory" "backtype.storm.serialization.DefaultKryoFactory", "worker.gc.childopts" "", "nimbus.topology.validator" "backtype.storm.nimbus.DefaultTopologyValidator", "nimbus.seeds" ["localhost"], "nimbus.cleanup.inbox.freq.secs" 600, "storm.blobstore.replication.factor" 3, "worker.heap.memory.mb" 768, "logviewer.max.sum.worker.logs.size.mb" 4096, "pacemaker.childopts" "-Xmx1024m", "ui.users" nil, "transactional.zookeeper.servers" nil, "supervisor.worker.timeout.secs" 30, "storm.zookeeper.auth.password" nil, "client.blobstore.class" "backtype.storm.blobstore.NimbusBlobStore", "supervisor.childopts" "-Xmx256m", "topology.worker.max.heap.size.mb" 768.0, "backpressure.disruptor.high.watermark" 0.9, "ui.filter" nil, "ui.header.buffer.bytes" 4096, "topology.min.replication.count" 1, "topology.disruptor.wait.timeout.millis" 1000, "storm.nimbus.retry.intervalceiling.millis" 60000, "topology.trident.batch.emit.interval.millis" 50, "storm.auth.simple-acl.users" [], "drpc.invocations.threads" 64, "java.library.path" "/usr/local/lib:/opt/local/lib:/usr/lib", "ui.port" 8080, "storm.messaging.netty.transfer.batch.size" 262144, "logviewer.appender.name" "A1", "nimbus.thrift.max_buffer_size" 1048576, "storm.auth.simple-acl.users.commands" [], "drpc.request.timeout.secs" 600} | |
| 7621 [storm.starter.ExclamationTopology.main()] INFO b.s.l.Localizer - Reconstruct localized resource: /var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T/4241d14c-c1e1-4c1e-8860-d58d35b9ac46/supervisor/usercache | |
| 7621 [storm.starter.ExclamationTopology.main()] WARN b.s.l.Localizer - No left over resources found for any user during reconstructing of local resources at: /var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T/4241d14c-c1e1-4c1e-8860-d58d35b9ac46/supervisor/usercache | |
| 7624 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7624 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000 sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@1b6a6e79 | |
| 7625 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7626 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/127.0.0.1:2000, initiating session | |
| 7626 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /127.0.0.1:56332 | |
| 7626 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /127.0.0.1:56332 | |
| 7627 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c4700008 with negotiated timeout 20000 for client /127.0.0.1:56332 | |
| 7627 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2000, sessionid = 0x151c5f3c4700008, negotiated timeout = 20000 | |
| 7627 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7627 [storm.starter.ExclamationTopology.main()-EventThread] INFO b.s.zookeeper - Zookeeper state update: :connected:none | |
| 7629 [ProcessThread(sid:0 cport:-1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Processed session termination for sessionid: 0x151c5f3c4700008 | |
| 7629 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shut down | |
| 7629 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Session: 0x151c5f3c4700008 closed | |
| 7630 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - Closed socket connection for client /127.0.0.1:56332 which had sessionid 0x151c5f3c4700008 | |
| 7630 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7631 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@58187629 | |
| 7632 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7632 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/0:0:0:0:0:0:0:1:2000, initiating session | |
| 7632 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /0:0:0:0:0:0:0:1:56333 | |
| 7633 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /0:0:0:0:0:0:0:1:56333 | |
| 7633 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c4700009 with negotiated timeout 20000 for client /0:0:0:0:0:0:0:1:56333 | |
| 7633 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/0:0:0:0:0:0:0:1:2000, sessionid = 0x151c5f3c4700009, negotiated timeout = 20000 | |
| 7633 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7658 [storm.starter.ExclamationTopology.main()] INFO b.s.d.supervisor - Starting supervisor with id c75196fe-4e6c-4d74-a03c-943b906a7b81 at host 192.168.1.9 | |
| 7662 [storm.starter.ExclamationTopology.main()] INFO b.s.d.supervisor - Starting Supervisor with conf {"topology.builtin.metrics.bucket.size.secs" 60, "nimbus.childopts" "-Xmx1024m", "ui.filter.params" nil, "storm.cluster.mode" "local", "storm.messaging.netty.client_worker_threads" 1, "logviewer.max.per.worker.logs.size.mb" 2048, "supervisor.run.worker.as.user" false, "topology.max.task.parallelism" nil, "topology.priority" 29, "zmq.threads" 1, "storm.group.mapping.service" "backtype.storm.security.auth.ShellBasedGroupsMapping", "transactional.zookeeper.root" "/transactional", "topology.sleep.spout.wait.strategy.time.ms" 1, "scheduler.display.resource" false, "topology.max.replication.wait.time.sec" 60, "drpc.invocations.port" 3773, "supervisor.localizer.cache.target.size.mb" 10240, "topology.multilang.serializer" "backtype.storm.multilang.JsonSerializer", "storm.messaging.netty.server_worker_threads" 1, "nimbus.blobstore.class" "backtype.storm.blobstore.LocalFsBlobStore", "resource.aware.scheduler.eviction.strategy" "backtype.storm.scheduler.resource.strategies.eviction.DefaultEvictionStrategy", "topology.max.error.report.per.interval" 5, "storm.thrift.transport" "backtype.storm.security.auth.SimpleTransportPlugin", "zmq.hwm" 0, "storm.group.mapping.service.params" nil, "worker.profiler.enabled" true, "storm.principal.tolocal" "backtype.storm.security.auth.DefaultPrincipalToLocal", "supervisor.worker.shutdown.sleep.secs" 1, "pacemaker.host" "localhost", "storm.zookeeper.retry.times" 5, "ui.actions.enabled" true, "zmq.linger.millis" 0, "supervisor.enable" true, "topology.stats.sample.rate" 0.05, "storm.messaging.netty.min_wait_ms" 100, "worker.log.level.reset.poll.secs" 30, "storm.zookeeper.port" 2000, "supervisor.heartbeat.frequency.secs" 5, "topology.enable.message.timeouts" true, "supervisor.cpu.capacity" 400.0, "drpc.worker.threads" 64, "supervisor.blobstore.download.thread.count" 5, "drpc.queue.size" 128, "topology.backpressure.enable" true, "supervisor.blobstore.class" "backtype.storm.blobstore.NimbusBlobStore", "storm.blobstore.inputstream.buffer.size.bytes" 65536, "topology.shellbolt.max.pending" 100, "drpc.https.keystore.password" "", "nimbus.code.sync.freq.secs" 120, "logviewer.port" 8000, "topology.scheduler.strategy" "backtype.storm.scheduler.resource.strategies.scheduling.DefaultResourceAwareStrategy", "topology.executor.send.buffer.size" 1024, "resource.aware.scheduler.priority.strategy" "backtype.storm.scheduler.resource.strategies.priority.DefaultSchedulingPriorityStrategy", "pacemaker.auth.method" "NONE", "topology.worker.logwriter.childopts" "-Xmx64m", "topology.spout.wait.strategy" "backtype.storm.spout.SleepSpoutWaitStrategy", "ui.host" "0.0.0.0", "storm.nimbus.retry.interval.millis" 2000, "nimbus.inbox.jar.expiration.secs" 3600, "dev.zookeeper.path" "/tmp/dev-storm-zookeeper", "topology.acker.executors" nil, "topology.fall.back.on.java.serialization" true, "topology.eventlogger.executors" nil, "supervisor.localizer.cleanup.interval.ms" 600000, "storm.zookeeper.servers" ["localhost"], "nimbus.thrift.threads" 64, "logviewer.cleanup.age.mins" 10080, "topology.worker.childopts" nil, "topology.classpath" nil, "supervisor.monitor.frequency.secs" 3, "nimbus.credential.renewers.freq.secs" 600, "topology.skip.missing.kryo.registrations" true, "drpc.authorizer.acl.filename" "drpc-auth-acl.yaml", "pacemaker.kerberos.users" [], "storm.group.mapping.service.cache.duration.secs" 120, "topology.testing.always.try.serialize" false, "nimbus.monitor.freq.secs" 10, "storm.health.check.timeout.ms" 5000, "supervisor.supervisors" [], "topology.tasks" nil, "topology.bolts.outgoing.overflow.buffer.enable" false, "storm.messaging.netty.socket.backlog" 500, "topology.workers" 1, "pacemaker.base.threads" 10, "storm.local.dir" "/var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T//e654a526-fd15-416a-8de4-2ce1b413c502", "topology.disable.loadaware" false, "worker.childopts" "-Xmx%HEAP-MEM%m -XX:+PrintGCDetails -Xloggc:artifacts/gc.log -XX:+PrintGCDateStamps -XX:+PrintGCTimeStamps -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=10 -XX:GCLogFileSize=1M -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=artifacts/heapdump", "storm.auth.simple-white-list.users" [], "topology.disruptor.batch.timeout.millis" 1, "topology.message.timeout.secs" 30, "topology.state.synchronization.timeout.secs" 60, "topology.tuple.serializer" "backtype.storm.serialization.types.ListDelegateSerializer", "supervisor.supervisors.commands" [], "nimbus.blobstore.expiration.secs" 600, "logviewer.childopts" "-Xmx128m", "topology.environment" nil, "topology.debug" false, "topology.disruptor.batch.size" 100, "storm.messaging.netty.max_retries" 300, "ui.childopts" "-Xmx768m", "storm.network.topography.plugin" "backtype.storm.networktopography.DefaultRackDNSToSwitchMapping", "storm.zookeeper.session.timeout" 20000, "drpc.childopts" "-Xmx768m", "drpc.http.creds.plugin" "backtype.storm.security.auth.DefaultHttpCredentialsPlugin", "storm.zookeeper.connection.timeout" 15000, "storm.zookeeper.auth.user" nil, "storm.meta.serialization.delegate" "backtype.storm.serialization.GzipThriftSerializationDelegate", "topology.max.spout.pending" nil, "storm.codedistributor.class" "backtype.storm.codedistributor.LocalFileSystemCodeDistributor", "nimbus.supervisor.timeout.secs" 60, "nimbus.task.timeout.secs" 30, "drpc.port" 3772, "pacemaker.max.threads" 50, "storm.zookeeper.retry.intervalceiling.millis" 30000, "nimbus.thrift.port" 6627, "storm.auth.simple-acl.admins" [], "topology.component.cpu.pcore.percent" 10.0, "supervisor.memory.capacity.mb" 3072.0, "storm.nimbus.retry.times" 5, "supervisor.worker.start.timeout.secs" 120, "storm.zookeeper.retry.interval" 1000, "logs.users" nil, "worker.profiler.command" "flight.bash", "transactional.zookeeper.port" nil, "drpc.max_buffer_size" 1048576, "pacemaker.thread.timeout" 10, "task.credentials.poll.secs" 30, "blobstore.superuser" "sethammons", "drpc.https.keystore.type" "JKS", "topology.worker.receiver.thread.count" 1, "supervisor.slots.ports" (1027 1028 1029), "topology.transfer.buffer.size" 1024, "storm.health.check.dir" "healthchecks", "topology.worker.shared.thread.pool.size" 4, "drpc.authorizer.acl.strict" false, "nimbus.file.copy.expiration.secs" 600, "worker.profiler.childopts" "-XX:+UnlockCommercialFeatures -XX:+FlightRecorder", "topology.executor.receive.buffer.size" 1024, "backpressure.disruptor.low.watermark" 0.4, "nimbus.task.launch.secs" 120, "storm.local.mode.zmq" false, "storm.messaging.netty.buffer_size" 5242880, "storm.cluster.state.store" "backtype.storm.cluster_state.zookeeper_state_factory", "worker.heartbeat.frequency.secs" 1, "storm.log4j2.conf.dir" "log4j2", "ui.http.creds.plugin" "backtype.storm.security.auth.DefaultHttpCredentialsPlugin", "storm.zookeeper.root" "/storm", "topology.tick.tuple.freq.secs" nil, "drpc.https.port" -1, "storm.workers.artifacts.dir" "workers-artifacts", "supervisor.blobstore.download.max_retries" 3, "task.refresh.poll.secs" 10, "task.heartbeat.frequency.secs" 3, "pacemaker.port" 6699, "storm.messaging.netty.max_wait_ms" 1000, "nimbus.impersonation.authorizer" "backtype.storm.security.auth.authorizer.ImpersonationAuthorizer", "topology.component.resources.offheap.memory.mb" 0.0, "drpc.http.port" 3774, "topology.error.throttle.interval.secs" 10, "storm.messaging.transport" "backtype.storm.messaging.netty.Context", "storm.messaging.netty.authentication" false, "topology.component.resources.onheap.memory.mb" 128.0, "topology.kryo.factory" "backtype.storm.serialization.DefaultKryoFactory", "worker.gc.childopts" "", "nimbus.topology.validator" "backtype.storm.nimbus.DefaultTopologyValidator", "nimbus.seeds" ["localhost"], "nimbus.cleanup.inbox.freq.secs" 600, "storm.blobstore.replication.factor" 3, "worker.heap.memory.mb" 768, "logviewer.max.sum.worker.logs.size.mb" 4096, "pacemaker.childopts" "-Xmx1024m", "ui.users" nil, "transactional.zookeeper.servers" nil, "supervisor.worker.timeout.secs" 30, "storm.zookeeper.auth.password" nil, "client.blobstore.class" "backtype.storm.blobstore.NimbusBlobStore", "supervisor.childopts" "-Xmx256m", "topology.worker.max.heap.size.mb" 768.0, "backpressure.disruptor.high.watermark" 0.9, "ui.filter" nil, "ui.header.buffer.bytes" 4096, "topology.min.replication.count" 1, "topology.disruptor.wait.timeout.millis" 1000, "storm.nimbus.retry.intervalceiling.millis" 60000, "topology.trident.batch.emit.interval.millis" 50, "storm.auth.simple-acl.users" [], "drpc.invocations.threads" 64, "java.library.path" "/usr/local/lib:/opt/local/lib:/usr/lib", "ui.port" 8080, "storm.messaging.netty.transfer.batch.size" 262144, "logviewer.appender.name" "A1", "nimbus.thrift.max_buffer_size" 1048576, "storm.auth.simple-acl.users.commands" [], "drpc.request.timeout.secs" 600} | |
| 7665 [storm.starter.ExclamationTopology.main()] INFO b.s.l.Localizer - Reconstruct localized resource: /var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T/e654a526-fd15-416a-8de4-2ce1b413c502/supervisor/usercache | |
| 7665 [storm.starter.ExclamationTopology.main()] WARN b.s.l.Localizer - No left over resources found for any user during reconstructing of local resources at: /var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T/e654a526-fd15-416a-8de4-2ce1b413c502/supervisor/usercache | |
| 7666 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7666 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000 sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@7b0381c5 | |
| 7667 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7668 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/0:0:0:0:0:0:0:1:2000, initiating session | |
| 7668 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /0:0:0:0:0:0:0:1:56334 | |
| 7668 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /0:0:0:0:0:0:0:1:56334 | |
| 7669 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c470000a with negotiated timeout 20000 for client /0:0:0:0:0:0:0:1:56334 | |
| 7669 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/0:0:0:0:0:0:0:1:2000, sessionid = 0x151c5f3c470000a, negotiated timeout = 20000 | |
| 7669 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7669 [storm.starter.ExclamationTopology.main()-EventThread] INFO b.s.zookeeper - Zookeeper state update: :connected:none | |
| 7670 [ProcessThread(sid:0 cport:-1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Processed session termination for sessionid: 0x151c5f3c470000a | |
| 7671 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Session: 0x151c5f3c470000a closed | |
| 7671 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shut down | |
| 7671 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - Closed socket connection for client /0:0:0:0:0:0:0:1:56334 which had sessionid 0x151c5f3c470000a | |
| 7672 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7672 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@77ba4bc4 | |
| 7673 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7673 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/0:0:0:0:0:0:0:1:2000, initiating session | |
| 7674 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /0:0:0:0:0:0:0:1:56335 | |
| 7674 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /0:0:0:0:0:0:0:1:56335 | |
| 7674 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c470000b with negotiated timeout 20000 for client /0:0:0:0:0:0:0:1:56335 | |
| 7675 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/0:0:0:0:0:0:0:1:2000, sessionid = 0x151c5f3c470000b, negotiated timeout = 20000 | |
| 7675 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7681 [storm.starter.ExclamationTopology.main()] INFO b.s.d.supervisor - Starting supervisor with id 9afce53a-5ea5-4786-b5f3-c2732a76d1e9 at host 192.168.1.9 | |
| 7697 [storm.starter.ExclamationTopology.main()] INFO b.s.l.ThriftAccessLogger - Request ID: 1 access from: principal: operation: submitTopology | |
| 7728 [storm.starter.ExclamationTopology.main()] INFO b.s.d.nimbus - Received topology submission for test with conf {"topology.max.task.parallelism" nil, "topology.submitter.principal" "", "topology.acker.executors" nil, "topology.eventlogger.executors" nil, "topology.debug" true, "storm.zookeeper.superACL" nil, "topology.users" (), "topology.submitter.user" "sethammons", "topology.kryo.register" nil, "topology.kryo.decorators" (), "storm.id" "test-1-1450725066", "topology.name" "test"} | |
| 7733 [storm.starter.ExclamationTopology.main()] INFO b.s.d.nimbus - uploadedJar | |
| 7744 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7745 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@2b4c837d | |
| 7746 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7747 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/127.0.0.1:2000, initiating session | |
| 7747 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /127.0.0.1:56336 | |
| 7747 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /127.0.0.1:56336 | |
| 7748 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c470000c with negotiated timeout 20000 for client /127.0.0.1:56336 | |
| 7749 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2000, sessionid = 0x151c5f3c470000c, negotiated timeout = 20000 | |
| 7749 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7751 [ProcessThread(sid:0 cport:-1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Got user-level KeeperException when processing sessionid:0x151c5f3c470000c type:create cxid:0x2 zxid:0x24 txntype:-1 reqpath:n/a Error Path:/storm/blobstoremaxkeysequencenumber Error:KeeperErrorCode = NoNode for /storm/blobstoremaxkeysequencenumber | |
| 7757 [ProcessThread(sid:0 cport:-1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Processed session termination for sessionid: 0x151c5f3c470000c | |
| 7757 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Session: 0x151c5f3c470000c closed | |
| 7757 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shut down | |
| 7758 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - Closed socket connection for client /127.0.0.1:56336 which had sessionid 0x151c5f3c470000c | |
| 7758 [storm.starter.ExclamationTopology.main()] INFO b.s.cluster - setup-path/blobstore/test-1-1450725066-stormconf.ser/192.168.1.9:6627-1 | |
| 7773 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 7773 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@1577b5b2 | |
| 7775 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/0:0:0:0:0:0:0:1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 7775 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/0:0:0:0:0:0:0:1:2000, initiating session | |
| 7775 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /0:0:0:0:0:0:0:1:56337 | |
| 7776 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /0:0:0:0:0:0:0:1:56337 | |
| 7777 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c470000d with negotiated timeout 20000 for client /0:0:0:0:0:0:0:1:56337 | |
| 7777 [storm.starter.ExclamationTopology.main(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/0:0:0:0:0:0:0:1:2000, sessionid = 0x151c5f3c470000d, negotiated timeout = 20000 | |
| 7777 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 7781 [ProcessThread(sid:0 cport:-1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Processed session termination for sessionid: 0x151c5f3c470000d | |
| 7782 [storm.starter.ExclamationTopology.main()-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shut down | |
| 7782 [storm.starter.ExclamationTopology.main()] INFO o.a.s.s.o.a.z.ZooKeeper - Session: 0x151c5f3c470000d closed | |
| 7782 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - Closed socket connection for client /0:0:0:0:0:0:0:1:56337 which had sessionid 0x151c5f3c470000d | |
| 7783 [storm.starter.ExclamationTopology.main()] INFO b.s.cluster - setup-path/blobstore/test-1-1450725066-stormcode.ser/192.168.1.9:6627-1 | |
| 7790 [storm.starter.ExclamationTopology.main()] INFO b.s.d.nimbus - desired replication count 1 achieved, current-replication-count for conf key = 1, current-replication-count for code key = 1, current-replication-count for jar key = 1 | |
| 7831 [storm.starter.ExclamationTopology.main()] INFO b.s.d.nimbus - Activating test: test-1-1450725066 | |
| 8553 [timer] INFO b.s.s.EvenScheduler - Available slots: (["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1025] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1026] ["9afce53a-5ea5-4786-b5f3-c2732a76d1e9" 1027] ["9afce53a-5ea5-4786-b5f3-c2732a76d1e9" 1028] ["9afce53a-5ea5-4786-b5f3-c2732a76d1e9" 1029]) | |
| 8572 [timer] INFO b.s.d.nimbus - Setting new assignment for topology id test-1-1450725066: #backtype.storm.daemon.common.Assignment{:master-code-dir "/var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T//15ce2e75-6fc1-48cd-9e8a-1e881a339206", :node->host {"c75196fe-4e6c-4d74-a03c-943b906a7b81" "192.168.1.9"}, :executor->node+port {[8 8] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [12 12] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [2 2] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [7 7] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [3 3] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [1 1] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [6 6] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [9 9] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [11 11] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [16 16] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [13 13] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [5 5] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [10 10] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [14 14] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [4 4] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [15 15] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024], [17 17] ["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024]}, :executor->start-time-secs {[8 8] 1450725067, [12 12] 1450725067, [2 2] 1450725067, [7 7] 1450725067, [3 3] 1450725067, [1 1] 1450725067, [6 6] 1450725067, [9 9] 1450725067, [11 11] 1450725067, [16 16] 1450725067, [13 13] 1450725067, [5 5] 1450725067, [10 10] 1450725067, [14 14] 1450725067, [4 4] 1450725067, [15 15] 1450725067, [17 17] 1450725067}, :worker->resources {["c75196fe-4e6c-4d74-a03c-943b906a7b81" 1024] [0.0 0.0 0.0]}} | |
| 8646 [Thread-8] INFO b.s.d.supervisor - Downloading code for storm id test-1-1450725066 | |
| 8648 [Thread-8] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 8649 [Thread-8] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@3edd5a92 | |
| 8649 [Thread-8] INFO b.s.b.FileBlobStoreImpl - Creating new blob store based in /var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T/15ce2e75-6fc1-48cd-9e8a-1e881a339206/blobs | |
| 8651 [Thread-8-SendThread(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 8651 [Thread-8-SendThread(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/127.0.0.1:2000, initiating session | |
| 8651 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /127.0.0.1:56338 | |
| 8652 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /127.0.0.1:56338 | |
| 8653 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c470000e with negotiated timeout 20000 for client /127.0.0.1:56338 | |
| 8653 [Thread-8-SendThread(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2000, sessionid = 0x151c5f3c470000e, negotiated timeout = 20000 | |
| 8653 [Thread-8-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 8672 [ProcessThread(sid:0 cport:-1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Processed session termination for sessionid: 0x151c5f3c470000e | |
| 8672 [Thread-8] INFO o.a.s.s.o.a.z.ZooKeeper - Session: 0x151c5f3c470000e closed | |
| 8672 [Thread-8-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shut down | |
| 8672 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - Closed socket connection for client /127.0.0.1:56338 which had sessionid 0x151c5f3c470000e | |
| 8690 [Thread-8] INFO b.s.d.supervisor - Copying resources at file:/Users/sethammons/playground/storm/storm/storm/examples/storm-starter/target/classes/resources to /var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T//4241d14c-c1e1-4c1e-8860-d58d35b9ac46/supervisor/stormdist/test-1-1450725066/resources | |
| 8693 [Thread-8] INFO b.s.d.supervisor - Finished downloading code for storm id test-1-1450725066 | |
| 8706 [Thread-9] INFO b.s.d.supervisor - Launching worker with assignment {:storm-id "test-1-1450725066", :executors [[8 8] [12 12] [2 2] [7 7] [3 3] [1 1] [6 6] [9 9] [11 11] [16 16] [13 13] [5 5] [10 10] [14 14] [4 4] [15 15] [17 17]], :resources #object[backtype.storm.generated.WorkerResources 0x7a1dc64c "WorkerResources(mem_on_heap:0.0, mem_off_heap:0.0, cpu:0.0)"]} for this supervisor c75196fe-4e6c-4d74-a03c-943b906a7b81 on port 1024 with id 00060eda-3463-441b-8fa6-423ba6dd85ca | |
| 8710 [Thread-9] INFO b.s.d.worker - Launching worker for test-1-1450725066 on c75196fe-4e6c-4d74-a03c-943b906a7b81:1024 with id 00060eda-3463-441b-8fa6-423ba6dd85ca and conf {"topology.builtin.metrics.bucket.size.secs" 60, "nimbus.childopts" "-Xmx1024m", "ui.filter.params" nil, "storm.cluster.mode" "local", "storm.messaging.netty.client_worker_threads" 1, "logviewer.max.per.worker.logs.size.mb" 2048, "supervisor.run.worker.as.user" false, "topology.max.task.parallelism" nil, "topology.priority" 29, "zmq.threads" 1, "storm.group.mapping.service" "backtype.storm.security.auth.ShellBasedGroupsMapping", "transactional.zookeeper.root" "/transactional", "topology.sleep.spout.wait.strategy.time.ms" 1, "scheduler.display.resource" false, "topology.max.replication.wait.time.sec" 60, "drpc.invocations.port" 3773, "supervisor.localizer.cache.target.size.mb" 10240, "topology.multilang.serializer" "backtype.storm.multilang.JsonSerializer", "storm.messaging.netty.server_worker_threads" 1, "nimbus.blobstore.class" "backtype.storm.blobstore.LocalFsBlobStore", "resource.aware.scheduler.eviction.strategy" "backtype.storm.scheduler.resource.strategies.eviction.DefaultEvictionStrategy", "topology.max.error.report.per.interval" 5, "storm.thrift.transport" "backtype.storm.security.auth.SimpleTransportPlugin", "zmq.hwm" 0, "storm.group.mapping.service.params" nil, "worker.profiler.enabled" true, "storm.principal.tolocal" "backtype.storm.security.auth.DefaultPrincipalToLocal", "supervisor.worker.shutdown.sleep.secs" 1, "pacemaker.host" "localhost", "storm.zookeeper.retry.times" 5, "ui.actions.enabled" true, "zmq.linger.millis" 0, "supervisor.enable" true, "topology.stats.sample.rate" 0.05, "storm.messaging.netty.min_wait_ms" 100, "worker.log.level.reset.poll.secs" 30, "storm.zookeeper.port" 2000, "supervisor.heartbeat.frequency.secs" 5, "topology.enable.message.timeouts" true, "supervisor.cpu.capacity" 400.0, "drpc.worker.threads" 64, "supervisor.blobstore.download.thread.count" 5, "drpc.queue.size" 128, "topology.backpressure.enable" true, "supervisor.blobstore.class" "backtype.storm.blobstore.NimbusBlobStore", "storm.blobstore.inputstream.buffer.size.bytes" 65536, "topology.shellbolt.max.pending" 100, "drpc.https.keystore.password" "", "nimbus.code.sync.freq.secs" 120, "logviewer.port" 8000, "topology.scheduler.strategy" "backtype.storm.scheduler.resource.strategies.scheduling.DefaultResourceAwareStrategy", "topology.executor.send.buffer.size" 1024, "resource.aware.scheduler.priority.strategy" "backtype.storm.scheduler.resource.strategies.priority.DefaultSchedulingPriorityStrategy", "pacemaker.auth.method" "NONE", "topology.worker.logwriter.childopts" "-Xmx64m", "topology.spout.wait.strategy" "backtype.storm.spout.SleepSpoutWaitStrategy", "ui.host" "0.0.0.0", "storm.nimbus.retry.interval.millis" 2000, "nimbus.inbox.jar.expiration.secs" 3600, "dev.zookeeper.path" "/tmp/dev-storm-zookeeper", "topology.acker.executors" nil, "topology.fall.back.on.java.serialization" true, "topology.eventlogger.executors" nil, "supervisor.localizer.cleanup.interval.ms" 600000, "storm.zookeeper.servers" ["localhost"], "nimbus.thrift.threads" 64, "logviewer.cleanup.age.mins" 10080, "topology.worker.childopts" nil, "topology.classpath" nil, "supervisor.monitor.frequency.secs" 3, "nimbus.credential.renewers.freq.secs" 600, "topology.skip.missing.kryo.registrations" true, "drpc.authorizer.acl.filename" "drpc-auth-acl.yaml", "pacemaker.kerberos.users" [], "storm.group.mapping.service.cache.duration.secs" 120, "topology.testing.always.try.serialize" false, "nimbus.monitor.freq.secs" 10, "storm.health.check.timeout.ms" 5000, "supervisor.supervisors" [], "topology.tasks" nil, "topology.bolts.outgoing.overflow.buffer.enable" false, "storm.messaging.netty.socket.backlog" 500, "topology.workers" 1, "pacemaker.base.threads" 10, "storm.local.dir" "/var/folders/3k/8srpztgn7776hlf7468rbrhr0000gp/T//4241d14c-c1e1-4c1e-8860-d58d35b9ac46", "topology.disable.loadaware" false, "worker.childopts" "-Xmx%HEAP-MEM%m -XX:+PrintGCDetails -Xloggc:artifacts/gc.log -XX:+PrintGCDateStamps -XX:+PrintGCTimeStamps -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=10 -XX:GCLogFileSize=1M -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=artifacts/heapdump", "storm.auth.simple-white-list.users" [], "topology.disruptor.batch.timeout.millis" 1, "topology.message.timeout.secs" 30, "topology.state.synchronization.timeout.secs" 60, "topology.tuple.serializer" "backtype.storm.serialization.types.ListDelegateSerializer", "supervisor.supervisors.commands" [], "nimbus.blobstore.expiration.secs" 600, "logviewer.childopts" "-Xmx128m", "topology.environment" nil, "topology.debug" false, "topology.disruptor.batch.size" 100, "storm.messaging.netty.max_retries" 300, "ui.childopts" "-Xmx768m", "storm.network.topography.plugin" "backtype.storm.networktopography.DefaultRackDNSToSwitchMapping", "storm.zookeeper.session.timeout" 20000, "drpc.childopts" "-Xmx768m", "drpc.http.creds.plugin" "backtype.storm.security.auth.DefaultHttpCredentialsPlugin", "storm.zookeeper.connection.timeout" 15000, "storm.zookeeper.auth.user" nil, "storm.meta.serialization.delegate" "backtype.storm.serialization.GzipThriftSerializationDelegate", "topology.max.spout.pending" nil, "storm.codedistributor.class" "backtype.storm.codedistributor.LocalFileSystemCodeDistributor", "nimbus.supervisor.timeout.secs" 60, "nimbus.task.timeout.secs" 30, "drpc.port" 3772, "pacemaker.max.threads" 50, "storm.zookeeper.retry.intervalceiling.millis" 30000, "nimbus.thrift.port" 6627, "storm.auth.simple-acl.admins" [], "topology.component.cpu.pcore.percent" 10.0, "supervisor.memory.capacity.mb" 3072.0, "storm.nimbus.retry.times" 5, "supervisor.worker.start.timeout.secs" 120, "storm.zookeeper.retry.interval" 1000, "logs.users" nil, "worker.profiler.command" "flight.bash", "transactional.zookeeper.port" nil, "drpc.max_buffer_size" 1048576, "pacemaker.thread.timeout" 10, "task.credentials.poll.secs" 30, "blobstore.superuser" "sethammons", "drpc.https.keystore.type" "JKS", "topology.worker.receiver.thread.count" 1, "supervisor.slots.ports" (1024 1025 1026), "topology.transfer.buffer.size" 1024, "storm.health.check.dir" "healthchecks", "topology.worker.shared.thread.pool.size" 4, "drpc.authorizer.acl.strict" false, "nimbus.file.copy.expiration.secs" 600, "worker.profiler.childopts" "-XX:+UnlockCommercialFeatures -XX:+FlightRecorder", "topology.executor.receive.buffer.size" 1024, "backpressure.disruptor.low.watermark" 0.4, "nimbus.task.launch.secs" 120, "storm.local.mode.zmq" false, "storm.messaging.netty.buffer_size" 5242880, "storm.cluster.state.store" "backtype.storm.cluster_state.zookeeper_state_factory", "worker.heartbeat.frequency.secs" 1, "storm.log4j2.conf.dir" "log4j2", "ui.http.creds.plugin" "backtype.storm.security.auth.DefaultHttpCredentialsPlugin", "storm.zookeeper.root" "/storm", "topology.tick.tuple.freq.secs" nil, "drpc.https.port" -1, "storm.workers.artifacts.dir" "workers-artifacts", "supervisor.blobstore.download.max_retries" 3, "task.refresh.poll.secs" 10, "task.heartbeat.frequency.secs" 3, "pacemaker.port" 6699, "storm.messaging.netty.max_wait_ms" 1000, "nimbus.impersonation.authorizer" "backtype.storm.security.auth.authorizer.ImpersonationAuthorizer", "topology.component.resources.offheap.memory.mb" 0.0, "drpc.http.port" 3774, "topology.error.throttle.interval.secs" 10, "storm.messaging.transport" "backtype.storm.messaging.netty.Context", "storm.messaging.netty.authentication" false, "topology.component.resources.onheap.memory.mb" 128.0, "topology.kryo.factory" "backtype.storm.serialization.DefaultKryoFactory", "worker.gc.childopts" "", "nimbus.topology.validator" "backtype.storm.nimbus.DefaultTopologyValidator", "nimbus.seeds" ["localhost"], "nimbus.cleanup.inbox.freq.secs" 600, "storm.blobstore.replication.factor" 3, "worker.heap.memory.mb" 768, "logviewer.max.sum.worker.logs.size.mb" 4096, "pacemaker.childopts" "-Xmx1024m", "ui.users" nil, "transactional.zookeeper.servers" nil, "supervisor.worker.timeout.secs" 30, "storm.zookeeper.auth.password" nil, "client.blobstore.class" "backtype.storm.blobstore.NimbusBlobStore", "supervisor.childopts" "-Xmx256m", "topology.worker.max.heap.size.mb" 768.0, "backpressure.disruptor.high.watermark" 0.9, "ui.filter" nil, "ui.header.buffer.bytes" 4096, "topology.min.replication.count" 1, "topology.disruptor.wait.timeout.millis" 1000, "storm.nimbus.retry.intervalceiling.millis" 60000, "topology.trident.batch.emit.interval.millis" 50, "storm.auth.simple-acl.users" [], "drpc.invocations.threads" 64, "java.library.path" "/usr/local/lib:/opt/local/lib:/usr/lib", "ui.port" 8080, "storm.messaging.netty.transfer.batch.size" 262144, "logviewer.appender.name" "A1", "nimbus.thrift.max_buffer_size" 1048576, "storm.auth.simple-acl.users.commands" [], "drpc.request.timeout.secs" 600} | |
| 8714 [Thread-9] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 8714 [Thread-9] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000 sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@31f3dae | |
| 8716 [Thread-9-SendThread(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 8717 [Thread-9-SendThread(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/127.0.0.1:2000, initiating session | |
| 8717 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /127.0.0.1:56339 | |
| 8717 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /127.0.0.1:56339 | |
| 8717 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c470000f with negotiated timeout 20000 for client /127.0.0.1:56339 | |
| 8718 [Thread-9-SendThread(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2000, sessionid = 0x151c5f3c470000f, negotiated timeout = 20000 | |
| 8718 [Thread-9-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 8718 [Thread-9-EventThread] INFO b.s.zookeeper - Zookeeper state update: :connected:none | |
| 8720 [ProcessThread(sid:0 cport:-1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - Processed session termination for sessionid: 0x151c5f3c470000f | |
| 8720 [Thread-9] INFO o.a.s.s.o.a.z.ZooKeeper - Session: 0x151c5f3c470000f closed | |
| 8720 [Thread-9-EventThread] INFO o.a.s.s.o.a.z.ClientCnxn - EventThread shut down | |
| 8721 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - Closed socket connection for client /127.0.0.1:56339 which had sessionid 0x151c5f3c470000f | |
| 8721 [Thread-9] INFO o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - Starting | |
| 8721 [Thread-9] INFO o.a.s.s.o.a.z.ZooKeeper - Initiating client connection, connectString=localhost:2000/storm sessionTimeout=20000 watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@29613fe0 | |
| 8723 [Thread-9-SendThread(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2000. Will not attempt to authenticate using SASL (unknown error) | |
| 8723 [Thread-9-SendThread(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Socket connection established to localhost/127.0.0.1:2000, initiating session | |
| 8723 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Accepted socket connection from /127.0.0.1:56340 | |
| 8723 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Client attempting to establish new session at /127.0.0.1:56340 | |
| 8724 [SyncThread:0] INFO o.a.s.s.o.a.z.s.ZooKeeperServer - Established session 0x151c5f3c4700010 with negotiated timeout 20000 for client /127.0.0.1:56340 | |
| 8724 [Thread-9-SendThread(localhost:2000)] INFO o.a.s.s.o.a.z.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2000, sessionid = 0x151c5f3c4700010, negotiated timeout = 20000 | |
| 8724 [Thread-9-EventThread] INFO o.a.s.s.o.a.c.f.s.ConnectionStateManager - State change: CONNECTED | |
| 8729 [Thread-9] INFO b.s.s.a.AuthUtils - Got AutoCreds [] | |
| 8733 [Thread-9] INFO b.s.d.worker - Reading Assignments. | |
| 8795 [Thread-9] INFO b.s.d.worker - Registering IConnectionCallbacks for c75196fe-4e6c-4d74-a03c-943b906a7b81:1024 | |
| 8838 [Thread-9] INFO b.s.d.executor - Loading executor word:[8 8] | |
| 8846 [Thread-9] ERROR b.s.d.worker - Error on initialization of server mk-worker | |
| java.lang.RuntimeException: java.lang.ClassNotFoundException: backtype.storm.testing.TestWordSpout | |
| at backtype.storm.utils.Utils.javaDeserialize(Utils.java:172) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at backtype.storm.utils.Utils.getSetComponentObject(Utils.java:402) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at backtype.storm.daemon.task$get_task_object.invoke(task.clj:74) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at backtype.storm.daemon.task$mk_task_data$fn__3991.invoke(task.clj:177) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at backtype.storm.util$assoc_apply_self.invoke(util.clj:934) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at backtype.storm.daemon.task$mk_task_data.invoke(task.clj:170) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at backtype.storm.daemon.task$mk_task.invoke(task.clj:181) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at backtype.storm.daemon.executor$mk_executor$fn__4210.invoke(executor.clj:366) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.core$map$fn__4553.invoke(core.clj:2622) ~[clojure-1.7.0.jar:?] | |
| at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.7.0.jar:?] | |
| at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.7.0.jar:?] | |
| at clojure.lang.RT.seq(RT.java:507) ~[clojure-1.7.0.jar:?] | |
| at clojure.core$seq__4128.invoke(core.clj:137) ~[clojure-1.7.0.jar:?] | |
| at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) ~[clojure-1.7.0.jar:?] | |
| at clojure.core.protocols$fn__6506.invoke(protocols.clj:101) ~[clojure-1.7.0.jar:?] | |
| at clojure.core.protocols$fn__6452$G__6447__6465.invoke(protocols.clj:13) ~[clojure-1.7.0.jar:?] | |
| at clojure.core$reduce.invoke(core.clj:6519) ~[clojure-1.7.0.jar:?] | |
| at clojure.core$into.invoke(core.clj:6600) ~[clojure-1.7.0.jar:?] | |
| at backtype.storm.daemon.executor$mk_executor.invoke(executor.clj:367) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at backtype.storm.daemon.worker$fn__5613$exec_fn__1365__auto__$reify__5615$iter__5620__5624$fn__5625.invoke(worker.clj:628) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.lang.LazySeq.sval(LazySeq.java:40) ~[clojure-1.7.0.jar:?] | |
| at clojure.lang.LazySeq.seq(LazySeq.java:49) ~[clojure-1.7.0.jar:?] | |
| at clojure.lang.RT.seq(RT.java:507) ~[clojure-1.7.0.jar:?] | |
| at clojure.core$seq__4128.invoke(core.clj:137) ~[clojure-1.7.0.jar:?] | |
| at clojure.core$dorun.invoke(core.clj:3009) ~[clojure-1.7.0.jar:?] | |
| at clojure.core$doall.invoke(core.clj:3025) ~[clojure-1.7.0.jar:?] | |
| at backtype.storm.daemon.worker$fn__5613$exec_fn__1365__auto__$reify__5615.run(worker.clj:628) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_60] | |
| at javax.security.auth.Subject.doAs(Subject.java:422) ~[?:1.8.0_60] | |
| at backtype.storm.daemon.worker$fn__5613$exec_fn__1365__auto____5614.invoke(worker.clj:600) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.lang.AFn.applyToHelper(AFn.java:178) ~[clojure-1.7.0.jar:?] | |
| at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.7.0.jar:?] | |
| at clojure.core$apply.invoke(core.clj:630) ~[clojure-1.7.0.jar:?] | |
| at backtype.storm.daemon.worker$fn__5613$mk_worker__5708.doInvoke(worker.clj:574) [storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.7.0.jar:?] | |
| at backtype.storm.daemon.supervisor$fn__6552.invoke(supervisor.clj:1168) [storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.lang.MultiFn.invoke(MultiFn.java:251) [clojure-1.7.0.jar:?] | |
| at backtype.storm.daemon.supervisor$get_valid_new_worker_ids$iter__6124__6128$fn__6129.invoke(supervisor.clj:377) [storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.lang.LazySeq.sval(LazySeq.java:40) [clojure-1.7.0.jar:?] | |
| at clojure.lang.LazySeq.seq(LazySeq.java:49) [clojure-1.7.0.jar:?] | |
| at clojure.lang.RT.seq(RT.java:507) [clojure-1.7.0.jar:?] | |
| at clojure.core$seq__4128.invoke(core.clj:137) [clojure-1.7.0.jar:?] | |
| at clojure.core$dorun.invoke(core.clj:3009) [clojure-1.7.0.jar:?] | |
| at clojure.core$doall.invoke(core.clj:3025) [clojure-1.7.0.jar:?] | |
| at backtype.storm.daemon.supervisor$get_valid_new_worker_ids.invoke(supervisor.clj:365) [storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at backtype.storm.daemon.supervisor$sync_processes.invoke(supervisor.clj:425) [storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.core$partial$fn__4527.invoke(core.clj:2492) [clojure-1.7.0.jar:?] | |
| at backtype.storm.event$event_manager$fn__5793.invoke(event.clj:40) [storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?] | |
| at java.lang.Thread.run(Thread.java:745) [?:1.8.0_60] | |
| Caused by: java.lang.ClassNotFoundException: backtype.storm.testing.TestWordSpout | |
| at java.net.URLClassLoader.findClass(URLClassLoader.java:381) ~[?:1.8.0_60] | |
| at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[?:1.8.0_60] | |
| at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331) ~[?:1.8.0_60] | |
| at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[?:1.8.0_60] | |
| at java.lang.Class.forName0(Native Method) ~[?:1.8.0_60] | |
| at java.lang.Class.forName(Class.java:348) ~[?:1.8.0_60] | |
| at org.apache.storm.shade.org.apache.commons.io.input.ClassLoaderObjectInputStream.resolveClass(ClassLoaderObjectInputStream.java:68) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1613) ~[?:1.8.0_60] | |
| at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1518) ~[?:1.8.0_60] | |
| at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1774) ~[?:1.8.0_60] | |
| at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) ~[?:1.8.0_60] | |
| at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371) ~[?:1.8.0_60] | |
| at backtype.storm.utils.Utils.javaDeserialize(Utils.java:166) ~[storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| ... 49 more | |
| 8854 [Thread-9] ERROR b.s.util - Halting process: ("Error on initialization") | |
| java.lang.RuntimeException: ("Error on initialization") | |
| at backtype.storm.util$exit_process_BANG_.doInvoke(util.clj:341) [storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?] | |
| at backtype.storm.daemon.worker$fn__5613$mk_worker__5708.doInvoke(worker.clj:574) [storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.7.0.jar:?] | |
| at backtype.storm.daemon.supervisor$fn__6552.invoke(supervisor.clj:1168) [storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.lang.MultiFn.invoke(MultiFn.java:251) [clojure-1.7.0.jar:?] | |
| at backtype.storm.daemon.supervisor$get_valid_new_worker_ids$iter__6124__6128$fn__6129.invoke(supervisor.clj:377) [storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.lang.LazySeq.sval(LazySeq.java:40) [clojure-1.7.0.jar:?] | |
| at clojure.lang.LazySeq.seq(LazySeq.java:49) [clojure-1.7.0.jar:?] | |
| at clojure.lang.RT.seq(RT.java:507) [clojure-1.7.0.jar:?] | |
| at clojure.core$seq__4128.invoke(core.clj:137) [clojure-1.7.0.jar:?] | |
| at clojure.core$dorun.invoke(core.clj:3009) [clojure-1.7.0.jar:?] | |
| at clojure.core$doall.invoke(core.clj:3025) [clojure-1.7.0.jar:?] | |
| at backtype.storm.daemon.supervisor$get_valid_new_worker_ids.invoke(supervisor.clj:365) [storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at backtype.storm.daemon.supervisor$sync_processes.invoke(supervisor.clj:425) [storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.core$partial$fn__4527.invoke(core.clj:2492) [clojure-1.7.0.jar:?] | |
| at backtype.storm.event$event_manager$fn__5793.invoke(event.clj:40) [storm-core-0.11.0-SNAPSHOT.jar:0.11.0-SNAPSHOT] | |
| at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?] | |
| at java.lang.Thread.run(Thread.java:745) [?:1.8.0_60] |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment