I see. but if I do not do this. the code "_.union(_)" in "(1 to consumerNum).map(_ => createStream[K, V, StringDecoder, StringDecoder](ssc, kafkaParams, topics, storageLevel)
    ).reduce(_.union(_))" does not compile successfully .