Skip to content

Instantly share code, notes, and snippets.

@kisabaka
Created March 13, 2012 21:23
Show Gist options
  • Save kisabaka/2031697 to your computer and use it in GitHub Desktop.
Save kisabaka/2031697 to your computer and use it in GitHub Desktop.
10964 [Thread-45] INFO backtype.storm.daemon.task - Emitting: 1 default ["mike"]
10966 [Thread-40] INFO backtype.storm.daemon.task - Emitting: 2 default ["mikelalala"]
11067 [Thread-45] INFO backtype.storm.daemon.task - Emitting: 1 default ["golda"]
11069 [Thread-40] INFO backtype.storm.daemon.task - Emitting: 2 default ["goldalalala"]
11169 [Thread-45] INFO backtype.storm.daemon.task - Emitting: 1 default ["bertels"]
11171 [Thread-40] INFO backtype.storm.daemon.task - Emitting: 2 default ["bertelslalala"]
11271 [Thread-45] INFO backtype.storm.daemon.task - Emitting: 1 default ["mike"]
11273 [Thread-40] INFO backtype.storm.daemon.task - Emitting: 2 default ["mikelalala"]
11373 [Thread-45] INFO backtype.storm.daemon.task - Emitting: 1 default ["jackson"]
11375 [Thread-40] INFO backtype.storm.daemon.task - Emitting: 2 default ["jacksonlalala"]
11474 [Thread-45] INFO backtype.storm.daemon.task - Emitting: 1 default ["nathan"]
11476 [Thread-40] INFO backtype.storm.daemon.task - Emitting: 2 default ["nathanlalala"]
11576 [Thread-45] INFO backtype.storm.daemon.task - Emitting: 1 default ["bertels"]
11579 [Thread-40] INFO backtype.storm.daemon.task - Emitting: 2 default ["bertelslalala"]
11678 [Thread-45] INFO backtype.storm.daemon.task - Emitting: 1 default ["nathan"]
11680 [Thread-40] INFO backtype.storm.daemon.task - Emitting: 2 default ["nathanlalala"]
11780 [Thread-45] INFO backtype.storm.daemon.task - Emitting: 1 default ["jackson"]
11782 [Thread-40] INFO backtype.storm.daemon.task - Emitting: 2 default ["jacksonlalala"]
11882 [Thread-45] INFO backtype.storm.daemon.task - Emitting: 1 default ["jackson"]
11883 [Thread-40] INFO backtype.storm.daemon.task - Emitting: 2 default ["jacksonlalala"]
11983 [Thread-45] INFO backtype.storm.daemon.task - Emitting: 1 default ["golda"]
11986 [Thread-40] INFO backtype.storm.daemon.task - Emitting: 2 default ["goldalalala"]
12009 [main] INFO backtype.storm.daemon.nimbus - Delaying event :remove for 3 secs for test-1-1331673532
12048 [main] INFO backtype.storm.daemon.nimbus - Updated test-1-1331673532 with status {:type :killed, :kill-time-secs 3}
12085 [Thread-45] INFO backtype.storm.daemon.task - Emitting: 1 default ["jackson"]
12088 [Thread-40] INFO backtype.storm.daemon.task - Emitting: 2 default ["jacksonlalala"]
14757 [Thread-2] INFO backtype.storm.daemon.nimbus - Killing topology: test-1-1331673532
14870 [Thread-14] INFO backtype.storm.daemon.supervisor - Removing code for storm id test-1-1331673532
14871 [Thread-9] INFO backtype.storm.daemon.supervisor - Removing code for storm id test-1-1331673532
14871 [Thread-4] INFO backtype.storm.daemon.supervisor - Removing code for storm id test-1-1331673532
14871 [Thread-19] INFO backtype.storm.daemon.supervisor - Removing code for storm id test-1-1331673532
14879 [Thread-15] INFO backtype.storm.daemon.supervisor - Shutting down and clearing state for id 9196cabd-0037-4d56-8662-2730ab221c36. State: :disallowed, Heartbeat: #:backtype.storm.daemon.common.WorkerHeartbeat{:time-secs 1331673545, :storm-id "test-1-1331673532", :task-ids (3), :port 7}
14879 [Thread-5] INFO backtype.storm.daemon.supervisor - Shutting down and clearing state for id 0b5e872b-09b4-4e00-8a64-b91244b6a6f1. State: :disallowed, Heartbeat: #:backtype.storm.daemon.common.WorkerHeartbeat{:time-secs 1331673545, :storm-id "test-1-1331673532", :task-ids (2), :port 1}
14880 [Thread-15] INFO backtype.storm.daemon.supervisor - Shutting down e98600cb-ee4c-40c2-804b-99kill: No such process
35919ba2b9:9196cabd-0037-4d56-8662-2730ab221c36
14880 [Thread-15] INFO backtype.storm.process-simulator - Killing process 718f0110-6dc8-4e9a-932c-e041d6b62d09
14880 [Thread-15] INFO backtype.storm.daemon.worker - Shutting down worker test-1-1331673532 e98600cb-ee4c-40c2-804b-9935919ba2b9 7
14881 [Thread-15] INFO backtype.storm.daemon.task - Shutting down task test-1-1331673532:3
14883 [Thread-45] INFO backtype.storm.util - Async loop interrupted!
14880 [Thread-5] INFO backtype.storm.daemon.supervisor - Shutting down 2655bee2-3282-40d1-8bb2-897d410230ae:0b5e872b-09b4-4e00-8a64-b91244b6a6f1
14883 [Thread-31] INFO backtype.storm.util - Async loop interrupted!
14885 [Thread-20] INFO backtype.storm.daemon.supervisor - Shutting down and clearing state for id 94847617-1ac0-4a01-bdae-b1f965b3eae6. State: :disallowed, Heartbeat: #:backtype.storm.daemon.common.WorkerHeartbeat{:time-secs 1331673545, :storm-id "test-1-1331673532", :task-ids (1), :port 10}
14885 [Thread-20] INFO backkill: No such process
type.storm.daemon.supervisor - Shutting down e7f4d4c5-71ff-4206-b257-c15617bd70d1:94847617-1ac0-4a01-bdae-b1f965b3eae6
14909 [Thread-15] INFO backtype.storm.daemon.task - Shut down task test-1-1331673532:3
14910 [Thread-15] INFO backtype.storm.daemon.worker - Terminating zmq context
14910 [Thread-15] INFO backtype.storm.daemon.worker - Disconnecting from storm cluster state context
14910 [Thread-15] INFO backtype.storm.daemon.worker - Waiting for heartbeat thread to die
14910 [Thread-47] INFO backtype.storm.util - Async loop interrupted!
14911 [Thread-48] INFO backtype.storm.util - Async loop interrupted!
14911 [Thread-28] INFO backtype.storm.util - Async loop interrupted!
14912 [Thread-25] INFO backtype.storm.event - Event manager interrupted
14917 [Thread-15] INFO backtype.storm.daemon.worker - Shut down worker test-1-1331673532 e98600cb-ee4c-40c2-804b-9935919ba2b9 7
14917 [Thread-20] INFO backtype.storm.process-simulator - Killing process 510a3978-2539-4620-a368-e1fdfba34c26
14917 [Thread-20] INFO backtype.storm.daemon.worker - Shutting down worker test-1-1331673532 e7f4d4c5-71ff-4206-b257-c15617bd70d1 10
14917 [Thread-20] INFO backtype.storm.daemon.task - Shutting down task test-1-1331673532:1
14918 [Thread-30] INFO backtype.storm.util - Async loop interrupted!
14940 [Thread-20] INFO backtype.storm.daemon.task - Shut down task test-1-1331673532:1
14940 [Thread-20] INFO backtype.storm.daemon.worker - Terminating zmq context
14940 [Thread-20] INFO backtype.storm.daemon.worker - Disconnecting from storm cluster state context
14940 [Thread-20] INFO backtype.storm.daemon.worker - Waiting for heartbeat thread to die
14941 [Thread-43] INFO backtype.storm.util - Async loop interrupted!
14943 [Thread-44] INFO backtype.storm.util - Async loop interrupted!
14943 [Thread-27] INFO backtype.storm.util - Async loop interrupted!
14944 [Thread-26] INFO backtype.storm.event - Event manager interrupted
14945 [Thread-40] ERROR org.apache.zookeeper.server.NIOServerCnxn - Thread Thread[Thread-40,5,main] died
java.lang.RuntimeException: Pipe to subprocess seems to be broken!
at backtype.storm.utils.ShellProcess.readString(ShellProcess.java:78)
at backtype.storm.utils.ShellProcess.readMap(ShellProcess.java:63)
at backtype.storm.task.ShellBolt$1.run(ShellBolt.java:83)
at java.lang.Thread.run(Thread.java:679)
14957 [Thread-20] INFO backtype.storm.daemon.worker - Shut down worker test-1-1331673532 e7f4d4c5-71ff-4206-b257-c15617bd70d1 10
14958 [Thread-5] INFO backtype.storm.process-simulator - Killing process 5504850f-135f-4644-bc7c-b57af26dde67
14958 [Thread-5] INFO backtype.storm.daemon.worker - Shutting down worker test-1-1331673532 2655bee2-3282-40d1-8bb2-897d410230ae 1
14958 [Thread-5] INFO backtype.storm.daemon.task - Shutting down task test-1-1331673532:2
14969 [Thread-32] INFO backtype.storm.util - Async loop interrupted!
14988 [Thread-15] INFO backtype.storm.util - Error when trying to kill 14879. Process is probably already dead.
14988 [Thread-20] INFO backtype.storm.util - Error when trying to kill 14881. Process is probably already dead.
14989 [Thread-20] INFO backtype.storm.daemon.supervisor - Shut down e7f4d4c5-71ff-4206-b257-c15617bd70d1:94847617-1ac0-4a01-bdae-b1f965b3eae6
14989 [Thread-15] INFO backtype.storm.daemon.supervisor - Shut down e98600cb-ee4c-40c2-804b-9935919ba2b9:9196cabd-0037-4d56-8662-2730ab221c36
14999 [Thread-5] INFO backtype.storm.daemon.task - Shut down task test-1-1331673532:2
14999 [Thread-5] INFO backtype.storm.daemon.worker - Terminating zmq context
14999 [Thread-5] INFO backtype.storm.daemon.worker - Disconnecting from storm cluster state context
14999 [Thread-5] INFO backtype.storm.daemon.worker - Waiting for heartbeat thread to die
14999 [Thread-38] INFO backtype.storm.util - Async loop interrupted!
14999 [Thread-39] INFO backtype.storm.util - Async loop interrupted!
15000 [Thread-29] INFO backtype.storm.util - Async loop interrupted!
15000 [Thread-24] INFO backtype.storm.event - Event manager interrupted
15007 [Thread-5] INFO backtype.storm.daemon.worker - Shut down worker test-1-1331673532 2655bee2-3282-40d1-8bb2-897d410230ae 1
15009 [Thread-5] INFO backtype.storm.daemon.supervisor - Shut down 2655bee2-3282-40d1-8bb2-897d410230ae:0b5e872b-09b4-4e00-8a64-b91244b6a6f1
21911 [Thread-2] INFO backtype.storm.daemon.nimbus - Cleaning up test-1-1331673532
22049 [main] INFO backtype.storm.daemon.nimbus - Shutting down master
22063 [main] INFO backtype.storm.daemon.nimbus - Shut down master
22081 [main] INFO backtype.storm.daemon.supervisor - Shutting down supervisor 2655bee2-3282-40d1-8bb2-897d410230ae
22082 [Thread-6] INFO backtype.storm.util - Async loop interrupted!
22082 [Thread-7] INFO backtype.storm.util - Async loop interrupted!
22083 [Thread-8] INFO backtype.storm.util - Async loop interrupted!
22083 [Thread-4] INFO backtype.storm.event - Event manager interrupted
22083 [Thread-5] INFO backtype.storm.event - Event manager interrupted
22096 [main] INFO backtype.storm.daemon.supervisor - Shutting down supervisor 2568fa02-d24a-4148-9393-f73f394f0e6e
22097 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181] WARN org.apache.zookeeper.server.NIOServerCnxn - EndOfStreamException: Unable to read additional data from client sessionid 0x1360ded81a10007, likely client has closed socket
22097 [Thread-11] INFO backtype.storm.util - Async loop interrupted!
22097 [Thread-12] INFO backtype.storm.util - Async loop interrupted!
22097 [Thread-13] INFO backtype.storm.util - Async loop interrupted!
22098 [Thread-9] INFO backtype.storm.event - Event manager interrupted
22098 [Thread-10] INFO backtype.storm.event - Event manager interrupted
22104 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181] WARN org.apache.zookeeper.server.NIOServerCnxn - EndOfStreamException: Unable to read additional data from client sessionid 0x1360ded81a10009, likely client has closed socket
22104 [main] INFO backtype.storm.daemon.supervisor - Shutting down supervisor e98600cb-ee4c-40c2-804b-9935919ba2b9
22104 [Thread-16] INFO backtype.storm.util - Async loop interrupted!
22105 [Thread-17] INFO backtype.storm.util - Async loop interrupted!
22105 [Thread-18] INFO backtype.storm.util - Async loop interrupted!
22105 [Thread-14] INFO backtype.storm.event - Event manager interrupted
22106 [Thread-15] INFO backtype.storm.event - Event manager interrupted
22113 [main] INFO backtype.storm.daemon.supervisor - Shutting down supervisor e7f4d4c5-71ff-4206-b257-c15617bd70d1
22113 [Thread-21] INFO backtype.storm.util - Async loop interrupted!
22113 [Thread-22] INFO backtype.storm.util - Async loop interrupted!
22114 [Thread-23] INFO backtype.storm.util - Async loop interrupted!
22114 [Thread-19] INFO backtype.storm.event - Event manager interrupted
22115 [Thread-20] INFO backtype.storm.event - Event manager interrupted
22146 [main] INFO backtype.storm.testing - Shutting down in process zookeeper
22149 [main] INFO backtype.storm.testing - Done shutting down in process zookeeper
22149 [main] INFO backtype.storm.testing - Deleting temporary path /tmp/6efc1fe3-f34d-45d0-a784-f4d7c7280e10
22150 [main] INFO backtype.storm.testing - Deleting temporary path /tmp/7566191b-63fb-4b2a-a5b0-82b7a4514900
22151 [main] INFO backtype.storm.testing - Deleting temporary path /tmp/764da028-ef37-4516-8f7f-077f635df22d
22153 [main] INFO backtype.storm.testing - Deleting temporary path /tmp/eb0d180c-9fb9-4fdf-91fe-44dad4ad1a14
22154 [main] INFO backtype.storm.testing - Deleting temporary path /tmp/1a371e10-cb65-4670-8f46-21994f8de931
22157 [main] INFO backtype.storm.testing - Deleting temporary path /tmp/dd1a5b92-abc2-45fe-8b3f-4fe4e9088751
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment