Storm Multilang: mixed message

[Alexandre Wilhelm <al...@gmail.com>]

Hi guys,

I’m facing an issue when using a topology in go with storm.

When running the topology with several workers (20) and parallelism (20) I can get mixed message in the console, for instance :

java.io.IOException: unable to parse: 449957326"],"command":"emit","need_task_ids":false,"tuple":["[{\"name\":\"syscall.write.count\",\"tags\":{\"priority\":\"minimum\",\"processID\":\"GPoEf\",\"serverID\":\"UUID\"},\"timestamp\":\"20160516173637\",\"value\":\"78\"},{\"name\":\"syscall.write.test\",\"tags\":{\"priority\":\"minimum\",\"processID\":\"GPoEf\",\"serverID\":\"UUID\"},\"timestamp\":\"20160516173637\",\"value\":\"62\"}]"]}
	at org.apache.storm.multilang.JsonSerializer.readMessage(JsonSerializer.java:173) ~[storm-core-1.0.1.jar:1.0.1]
	at org.apache.storm.multilang.JsonSerializer.readShellMsg(JsonSerializer.java:103) ~[storm-core-1.0.1.jar:1.0.1]
	at org.apache.storm.utils.ShellProcess.readShellMsg(ShellProcess.java:120) ~[storm-core-1.0.1.jar:1.0.1]
	at org.apache.storm.task.ShellBolt$BoltReaderRunnable.run(ShellBolt.java:333) [storm-core-1.0.1.jar:1.0.1]
	at java.lang.Thread.run(Thread.java:745) [?:1.8.0_20-ea]
177703 [Thread-124] ERROR o.a.s.d.executor - 

Here we can see the last chars of the previous message and a new message. The messages are randomly cut.

Is it normal as several processes are writing in the same console, or something is wrong with my setup ? This issue does not happen when not having parallelism and several workers.

Running on storm 1.0.1

Thanks and sorry if it’s not a relevant question. 
-- 
Alexandre Wilhelm