Do you really need to iterate ? On Mon, Oct 19, 2015 at 5:42 PM, flinkuser <[email protected]> wrote:
> > Here is my code snippet but I find the union operator not workable. > > DataStream<String> msgDataStream1 = env.addSource((new > SocketSource(hostName1,port,'\n',-1))).filter(new > MessageFilter()).setParallelism(1); > DataStream<String> msgDataStream2 = env.addSource((new > SocketSource(hostName2,port,'\n',-1))).filter(new > MessageFilter()).setParallelism(1); > > > DataStream<String> stockStream = > (msgDataStream1.union(msgDataStream2)).iterate(); > stockStream.print(); > > > The stockStream doesn’t print the consolidated stream data. Sometimes > Stream1 is printed, sometimes none is printed. > > Can you please help me out, as of what is wrong here. > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Data-Stream-Union-tp3169.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
