Re: Flink Data Stream Union

2015-10-21 Thread Stephan Ewen
; msgDataStream1.union(msgDataStream2); > > ds.print(); > > } catch (Exception e) { > > System.err.println("Exception in union Message > Streams () = > " + > > e.getMessage()); > > } > > } > > > > Thanks > > > > > > > > -- > > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Data-Stream-Union-tp3169p3196.html > > Sent from the Apache Flink User Mailing List archive. mailing list > archive at Nabble.com. > >

Re: Flink Data Stream Union

2015-10-21 Thread Aljoscha Krettek
> () = > " + > e.getMessage()); > } > } > > Thanks > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Data-Stream-Union-tp3169p3196.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.

Re: Flink Data Stream Union

2015-10-21 Thread Aljoscha Krettek
race(); > > > > } > > > > } > > > > > > > > private static void unionMessageStreams(DataStream > > > > msgDataStream1, > > > > DataStream msgDataStream2) { > > > > try { > > > > > > > > DataStream ds = > > > > msgDataStream1.union(msgDataStream2); > > > > ds.print(); > > > > } catch (Exception e) { > > > > System.err.println("Exception in union Message > > > > Streams () = > " + > > > > e.getMessage()); > > > > } > > > > } > > > > > > > > Thanks > > > > > > > > > > > > > > > > -- > > > > View this message in context: > > > > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Data-Stream-Union-tp3169p3196.html > > > > Sent from the Apache Flink User Mailing List archive. mailing list > > > > archive at Nabble.com. > > > > > > > > > > > > > > > > > > > -- > > > Gayu > > > > > > > > > > -- > > Gayu > > > > > -- > Gayu

Re: Flink Data Stream Union

2015-10-21 Thread Gayu
tion e) { > > > > System.err.println("Exception = > " + > e.getMessage()); > > > > e.printStackTrace(); > > > > } > > > > } > > > > > > > > private static void unionMessageStreams(DataS

Re: Flink Data Stream Union

2015-10-21 Thread Aljoscha Krettek
> > > e.getMessage()); > > > e.printStackTrace(); > > > } > > > } > > > > > > private static void unionMessageStreams(DataStream > > > msgDataStream1, > > > DataStream

Re: Flink Data Stream Union

2015-10-21 Thread Gayu
e(); > > > } > > > } > > > > > > private static void unionMessageStreams(DataStream > msgDataStream1, > > > DataStream msgDataStream2) { > > > try { > > > > > > Da

Re: Flink Data Stream Union

2015-10-21 Thread Aljoscha Krettek
onMessageStreams(DataStream > > msgDataStream1, > > DataStream msgDataStream2) { > > try { > > > > DataStream ds = > > msgDataStream1.union(msgDataStream2); > > ds.print(); > >

Re: Flink Data Stream Union

2015-10-21 Thread Gayu
; > > DataStream ds = > msgDataStream1.union(msgDataStream2); > > ds.print(); > > } catch (Exception e) { > > System.err.println("Exception in union Message > Streams () = > " + > > e.getMessage()); > > } > > } > > > > Thanks > > > > > > > > -- > > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Data-Stream-Union-tp3169p3196.html > > Sent from the Apache Flink User Mailing List archive. mailing list > archive at Nabble.com. > > > > -- Gayu

Re: Flink Data Stream Union

2015-10-21 Thread Aljoscha Krettek
try { > > DataStream ds = > msgDataStream1.union(msgDataStream2); > ds.print(); > } catch (Exception e) { > System.err.println("Exception in union Message > Streams () = > " + > e.getMe

Re: Flink Data Stream Union

2015-10-21 Thread Till Rohrmann
DataStream ds = > msgDataStream1.union(msgDataStream2); > ds.print(); > } catch (Exception e) { > System.err.println("Exception in union Message > Streams () = > " + > e.getMessag

Re: Flink Data Stream Union

2015-10-21 Thread flinkuser
hanks -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-Data-Stream-Union-tp3169p3196.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Flink Data Stream Union

2015-10-20 Thread Stephan Ewen
;> 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. >> > >

Re: Flink Data Stream Union

2015-10-19 Thread Anwar Rizal
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 messa

Flink Data Stream Union

2015-10-19 Thread flinkuser
d, 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.