lundi 3 août 2015

Storm test case backtype.storm.multilang failed with backtype.storm.multilang.NoOutputException exception

I clone the latest version (master) of Storm source code from http://ift.tt/1OZiCIH. I am using Ubuntu 14.02.

But when I run "mvn test" command, the test process fails and terminates at backtype.storm.multilang-test.

Here is the context of backtype.storm.multilang-test.xml file:

171293 [Thread-1212-1] ERROR b.s.util - Async loop died!
java.lang.RuntimeException: backtype.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read.
Serializer Exception:


    at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:91) ~[classes/:?]
    at backtype.storm.spout.ShellSpout.open(ShellSpout.java:84) ~[classes/:?]
    at backtype.storm.daemon.executor$fn__4594$fn__4609.invoke(executor.clj:559) ~[classes/:?]
    at backtype.storm.util$async_loop$fn__643.invoke(util.clj:473) [classes/:?]
    at clojure.lang.AFn.run(AFn.java:22) [clojure-1.6.0.jar:?]
    at java.lang.Thread.run(Thread.java:745) [?:1.7.0_79]
171294 [Thread-1212-1] ERROR b.s.d.executor - 
java.lang.RuntimeException: backtype.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read.
Serializer Exception:


    at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:91) ~[classes/:?]
    at backtype.storm.spout.ShellSpout.open(ShellSpout.java:84) ~[classes/:?]
    at backtype.storm.daemon.executor$fn__4594$fn__4609.invoke(executor.clj:559) ~[classes/:?]
    at backtype.storm.util$async_loop$fn__643.invoke(util.clj:473) [classes/:?]
    at clojure.lang.AFn.run(AFn.java:22) [clojure-1.6.0.jar:?]
    at java.lang.Thread.run(Thread.java:745) [?:1.7.0_79]
171297 [Thread-1221-2] INFO  b.s.d.executor - Preparing bolt 2:(2)
171297 [Thread-1221-2] INFO  b.s.u.ShellProcess - Storm multilang serializer: backtype.storm.multilang.JsonSerializer
171298 [Thread-1203-EventThread] INFO  o.a.c.f.s.ConnectionStateManager - State change: CONNECTED
171300 [Thread-1217-__acker] INFO  b.s.d.executor - Preparing bolt __acker:(13)
171301 [Thread-1217-__acker] INFO  b.s.d.executor - Prepared bolt __acker:(13)
171301 [Thread-1214-__system] INFO  b.s.d.executor - Preparing bolt __system:(-1)
171300 [Thread-1226-__acker] INFO  b.s.d.executor - Preparing bolt __acker:(3)
171302 [Thread-1214-__system] INFO  b.s.d.executor - Prepared bolt __system:(-1)
171302 [Thread-1226-__acker] INFO  b.s.d.executor - Prepared bolt __acker:(3)
171302 [Thread-1228-__acker] INFO  b.s.d.executor - Preparing bolt __acker:(14)
171302 [Thread-1228-__acker] INFO  b.s.d.executor - Prepared bolt __acker:(14)
171300 [Thread-1223-__system] INFO  b.s.d.executor - Preparing bolt __system:(-1)
171304 [Thread-1223-__system] INFO  b.s.d.executor - Prepared bolt __system:(-1)
171304 [Thread-1221-2] ERROR b.s.util - Async loop died!
java.lang.RuntimeException: Error when launching multilang subprocess

    at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:87) ~[classes/:?]
    at backtype.storm.task.ShellBolt.prepare(ShellBolt.java:126) ~[classes/:?]
    at backtype.storm.daemon.executor$fn__4664$fn__4677.invoke(executor.clj:755) ~[classes/:?]
    at backtype.storm.util$async_loop$fn__643.invoke(util.clj:473) [classes/:?]
    at clojure.lang.AFn.run(AFn.java:22) [clojure-1.6.0.jar:?]
    at java.lang.Thread.run(Thread.java:745) [?:1.7.0_79]
Caused by: java.io.IOException: Broken pipe
    at java.io.FileOutputStream.writeBytes(Native Method) ~[?:1.7.0_79]
    at java.io.FileOutputStream.write(FileOutputStream.java:345) ~[?:1.7.0_79]
    at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:82) ~[?:1.7.0_79]
    at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:140) ~[?:1.7.0_79]
    at java.io.DataOutputStream.flush(DataOutputStream.java:123) ~[?:1.7.0_79]
    at backtype.storm.multilang.JsonSerializer.writeString(JsonSerializer.java:96) ~[classes/:?]
    at backtype.storm.multilang.JsonSerializer.writeMessage(JsonSerializer.java:89) ~[classes/:?]
    at backtype.storm.multilang.JsonSerializer.connect(JsonSerializer.java:61) ~[classes/:?]
    at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:85) ~[classes/:?]
    ... 5 more
171306 [Thread-1221-2] ERROR b.s.d.executor - 
java.lang.RuntimeException: Error when launching multilang subprocess

    at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:87) ~[classes/:?]
    at backtype.storm.task.ShellBolt.prepare(ShellBolt.java:126) ~[classes/:?]
    at backtype.storm.daemon.executor$fn__4664$fn__4677.invoke(executor.clj:755) ~[classes/:?]
    at backtype.storm.util$async_loop$fn__643.invoke(util.clj:473) [classes/:?]
    at clojure.lang.AFn.run(AFn.java:22) [clojure-1.6.0.jar:?]
    at java.lang.Thread.run(Thread.java:745) [?:1.7.0_79]
Caused by: java.io.IOException: Broken pipe
    at java.io.FileOutputStream.writeBytes(Native Method) ~[?:1.7.0_79]
    at java.io.FileOutputStream.write(FileOutputStream.java:345) ~[?:1.7.0_79]
    at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:82) ~[?:1.7.0_79]
    at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:140) ~[?:1.7.0_79]
    at java.io.DataOutputStream.flush(DataOutputStream.java:123) ~[?:1.7.0_79]
    at backtype.storm.multilang.JsonSerializer.writeString(JsonSerializer.java:96) ~[classes/:?]
    at backtype.storm.multilang.JsonSerializer.writeMessage(JsonSerializer.java:89) ~[classes/:?]
    at backtype.storm.multilang.JsonSerializer.connect(JsonSerializer.java:61) ~[classes/:?]
    at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:85) ~[classes/:?]
    ... 5 more
171308 [Thread-1231-__system] INFO  b.s.d.executor - Preparing bolt __system:(-1)
171308 [Thread-1231-__system] INFO  b.s.d.executor - Prepared bolt __system:(-1)
171309 [Thread-1233-__system] INFO  b.s.d.executor - Preparing bolt __system:(-1)
171310 [Thread-1233-__system] INFO  b.s.d.executor - Prepared bolt __system:(-1)
171315 [Thread-1235-__acker] INFO  b.s.d.executor - Preparing bolt __acker:(15)
171315 [Thread-1203] INFO  b.s.s.a.AuthUtils - Got AutoCreds []
171315 [Thread-1235-__acker] INFO  b.s.d.executor - Prepared bolt __acker:(15)
171315 [Thread-1203] INFO  b.s.d.worker - Reading Assignments.
171316 [Thread-1238-__acker] INFO  b.s.d.executor - Preparing bolt __acker:(16)
171316 [Thread-1238-__acker] INFO  b.s.d.executor - Prepared bolt __acker:(16)
171319 [refresh-active-timer] INFO  b.s.d.worker - All connections are ready for worker 7dea90e5-ca16-4136-a112-88d756cd9014:1028 with id a74f15a4-ce44-4959-89a5-483b4aff164f
171324 [Thread-1203] INFO  b.s.d.worker - Launching receive-thread for 6737d54e-6cc5-4de7-af27-171ba758fb5b:1025
171325 [Thread-1286-worker-receiver-thread-0] INFO  b.s.m.loader - Starting receive-thread: [stormId: test-1-1438588543, port: 1025, thread-id: 0 ]
171325 [Thread-1240-__acker] INFO  b.s.d.executor - Preparing bolt __acker:(4)
171325 [Thread-1240-__acker] INFO  b.s.d.executor - Prepared bolt __acker:(4)
171325 [Thread-1212-1] ERROR b.s.util - Halting process: ("Worker died")
java.lang.RuntimeException: ("Worker died")
    at backtype.storm.util$exit_process_BANG_.doInvoke(util.clj:332) [classes/:?]
    at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.6.0.jar:?]
    at backtype.storm.daemon.worker$fn__5151$fn__5152.invoke(worker.clj:532) [classes/:?]
    at backtype.storm.daemon.executor$mk_executor_data$fn__4493$fn__4494.invoke(executor.clj:261) [classes/:?]
    at backtype.storm.util$async_loop$fn__643.invoke(util.clj:485) [classes/:?]
    at clojure.lang.AFn.run(AFn.java:22) [clojure-1.6.0.jar:?]
    at java.lang.Thread.run(Thread.java:745) [?:1.7.0_79]
171325 [Thread-1221-2] ERROR b.s.util - Halting process: ("Worker died")
java.lang.RuntimeException: ("Worker died")
    at backtype.storm.util$exit_process_BANG_.doInvoke(util.clj:332) [classes/:?]
    at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.6.0.jar:?]
    at backtype.storm.daemon.worker$fn__5151$fn__5152.invoke(worker.clj:532) [classes/:?]
    at backtype.storm.daemon.executor$mk_executor_data$fn__4493$fn__4494.invoke(executor.clj:261) [classes/:?]
    at backtype.storm.util$async_loop$fn__643.invoke(util.clj:485) [classes/:?]
    at clojure.lang.AFn.run(AFn.java:22) [clojure-1.6.0.jar:?]
    at java.lang.Thread.run(Thread.java:745) [?:1.7.0_79]

Any help is highly appreciated.

Aucun commentaire:

Enregistrer un commentaire