flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Till Rohrmann <trohrm...@apache.org>
Subject Re: Flink Data Stream Union
Date Wed, 21 Oct 2015 13:29:31 GMT
Can it be that you forgot to call unionMessageStreams in your main method?

Cheers,
Till
‚Äč

On Wed, Oct 21, 2015 at 3:02 PM, flinkuser <gaayuu@gmail.com> wrote:

> Here is the strange behavior.
>
> Below code works in one box but not in the other. I had it working in my
> laptop the whole of yesterday, but strangely today it doesnt work in my
> desktop.
>
> Can anyone please let me know what the issue is.
>
>
> public static void main(String[] args) throws Exception {
>                 try {
>                         final StreamExecutionEnvironment env =
> StreamExecutionEnvironment.getExecutionEnvironment();
>                         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);
>
>                         env.execute("Stock stream");
>
>                 } catch (Exception e) {
>                         System.err.println("Exception  = > " +
> e.getMessage());
>                         e.printStackTrace();
>                 }
>         }
>
>         private static void unionMessageStreams(DataStream<String>
> msgDataStream1,
> DataStream<String> msgDataStream2) {
>                 try {
>
>                         DataStream<String> 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.
>

Mime
View raw message