// Give the multi-thread pipeline a second.sink.next("a"); sink.next("c");
// It's multi-thread so wait// Give the multi-thread pipeline a second.sink2.next("a&qu
64-Bit Server VM (build 24.75-b04, mixed mode)SEVERE: Error waiting for multi-threadjava.util.concurrent.ExecutionException: java.lang.OutOfMemoryError: Java heap space
SEVERE: Error waiting for multi-thread