Return-Path: 
 <user-return-3161-apmail-flink-user-archive=flink.apache.org@flink.apache.org>
X-Original-To: apmail-flink-user-archive@minotaur.apache.org
Delivered-To: apmail-flink-user-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 7CD3617F0D
	for <apmail-flink-user-archive@minotaur.apache.org>;
 Wed, 21 Oct 2015 13:29:46 +0000 (UTC)
Received: (qmail 83204 invoked by uid 500); 21 Oct 2015 13:29:33 -0000
Delivered-To: apmail-flink-user-archive@flink.apache.org
Received: (qmail 83132 invoked by uid 500); 21 Oct 2015 13:29:33 -0000
Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@flink.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@flink.apache.org>
List-Post: <mailto:user@flink.apache.org>
List-Id: <user.flink.apache.org>
Reply-To: user@flink.apache.org
Delivered-To: mailing list user@flink.apache.org
Received: (qmail 83123 invoked by uid 99); 21 Oct 2015 13:29:33 -0000
Received: from mail-relay.apache.org (HELO mail-relay.apache.org)
 (140.211.11.15)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 21 Oct 2015 13:29:33 +0000
Received: from mail-wi0-f179.google.com (mail-wi0-f179.google.com
 [209.85.212.179])
	by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with
 ESMTPSA id 179AB1A0181
	for <user@flink.apache.org>; Wed, 21 Oct 2015 13:29:33 +0000 (UTC)
Received: by wicfx6 with SMTP id fx6so91414340wic.1
        for <user@flink.apache.org>; Wed, 21 Oct 2015 06:29:31 -0700 (PDT)
MIME-Version: 1.0
X-Received: by 10.180.24.42 with SMTP id r10mr8783632wif.46.1445434171973;
 Wed, 21 Oct 2015 06:29:31 -0700 (PDT)
Received: by 10.28.139.69 with HTTP; Wed, 21 Oct 2015 06:29:31 -0700 (PDT)
In-Reply-To: <1445432540789-3196.post@n4.nabble.com>
References: <1445269349187-3169.post@n4.nabble.com>
	<CANfS33DkNfgUB+n9=gGd9SgEDONyHTPzDUf9sGd-ZMqi3K3X+w@mail.gmail.com>
	<CANC1h_vrU3uNbC=hsb2QTu-HPgDTUa7_SpWOVOeC4QP9frvNUQ@mail.gmail.com>
	<CA+ybEFhxa6KN=DBVDE2gsiKbw4hjebKn-wP3QiJn-qLh_RZBSA@mail.gmail.com>
	<1445432540789-3196.post@n4.nabble.com>
Date: Wed, 21 Oct 2015 15:29:31 +0200
Message-ID: 
 <CAC27z=OTPc2CqGTOjhMMXTHTXtyeA0mmYLGtx9i3wKw54OF6Qg@mail.gmail.com>
Subject: Re: Flink Data Stream Union
From: Till Rohrmann <trohrmann@apache.org>
To: user@flink.apache.org
Content-Type: multipart/alternative; boundary=f46d043c807a5df11a05229d5e69

--f46d043c807a5df11a05229d5e69
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

Can it be that you forgot to call unionMessageStreams in your main method?

Cheers,
Till
=E2=80=8B

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 =3D
> StreamExecutionEnvironment.getExecutionEnvironment();
>                         DataStream<String> msgDataStream1 =3D
> env.addSource((new
> SocketSource(hostName1, port, '\n', -1))).filter(new
> MessageFilter()).setParallelism(1);
>                         DataStream<String> msgDataStream2 =3D
> env.addSource((new
> SocketSource(hostName2, port, '\n', -1))).filter(new
> MessageFilter()).setParallelism(1);
>
>                         env.execute("Stock stream");
>
>                 } catch (Exception e) {
>                         System.err.println("Exception  =3D > " +
> e.getMessage());
>                         e.printStackTrace();
>                 }
>         }
>
>         private static void unionMessageStreams(DataStream<String>
> msgDataStream1,
> DataStream<String> msgDataStream2) {
>                 try {
>
>                         DataStream<String> ds =3D
> msgDataStream1.union(msgDataStream2);
>                         ds.print();
>                 } catch (Exception e) {
>                         System.err.println("Exception in union Message
> Streams () =3D > " +
> 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 archiv=
e
> at Nabble.com.
>

--f46d043c807a5df11a05229d5e69
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr"><div class=3D"markdown-here-wrapper" style=3D""><p style=
=3D"margin:0px 0px 1.2em!important">Can it be that you forgot to call <code=
 style=3D"font-size:0.85em;font-family:Consolas,Inconsolata,Courier,monospa=
ce;margin:0px 0.15em;padding:0px 0.3em;white-space:pre-wrap;border:1px soli=
d rgb(234,234,234);border-radius:3px;display:inline;background-color:rgb(24=
8,248,248)">unionMessageStreams</code> in your <code style=3D"font-size:0.8=
5em;font-family:Consolas,Inconsolata,Courier,monospace;margin:0px 0.15em;pa=
dding:0px 0.3em;white-space:pre-wrap;border:1px solid rgb(234,234,234);bord=
er-radius:3px;display:inline;background-color:rgb(248,248,248)">main</code>=
 method?</p>
<p style=3D"margin:0px 0px 1.2em!important">Cheers,<br>Till</p>
<div title=3D"MDH:Q2FuIGl0IGJlIHRoYXQgeW91IGZvcmdvdCB0byBjYWxsIGB1bmlvbk1lc=
3NhZ2VTdHJlYW1zYCBp
biB5b3VyIGBtYWluYCBtZXRob2Q/PGRpdj48YnI+PC9kaXY+PGRpdj5DaGVlcnMsPC9kaXY+PGR=
p
dj5UaWxsPC9kaXY+" style=3D"height:0;width:0;max-height:0;max-width:0;overfl=
ow:hidden;font-size:0em;padding:0;margin:0">=E2=80=8B</div></div></div><div=
 class=3D"gmail_extra"><br><div class=3D"gmail_quote">On Wed, Oct 21, 2015 =
at 3:02 PM, flinkuser <span dir=3D"ltr">&lt;<a href=3D"mailto:gaayuu@gmail.=
com" target=3D"_blank">gaayuu@gmail.com</a>&gt;</span> wrote:<br><blockquot=
e class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc sol=
id;padding-left:1ex">Here is the strange behavior.<br>
<br>
Below code works in one box but not in the other. I had it working in my<br=
>
laptop the whole of yesterday, but strangely today it doesnt work in my<br>
desktop.<br>
<br>
Can anyone please let me know what the issue is.<br>
<br>
<br>
public static void main(String[] args) throws Exception {<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 try {<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 final StreamExecutionEnvironment env =3D<br>
StreamExecutionEnvironment.getExecutionEnvironment();<br>
<span class=3D"">=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =
=C2=A0 =C2=A0 =C2=A0 =C2=A0 DataStream&lt;String&gt; msgDataStream1 =3D env=
.addSource((new<br>
SocketSource(hostName1, port, &#39;\n&#39;, -1))).filter(new<br>
MessageFilter()).setParallelism(1);<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 DataStream&lt;String&gt; msgDataStream2 =3D env.addSource((new<b=
r>
SocketSource(hostName2, port, &#39;\n&#39;, -1))).filter(new<br>
MessageFilter()).setParallelism(1);<br>
<br>
</span>=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0 env.execute(&quot;Stock stream&quot;);<br>
<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 } catch (Exception =
e) {<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 System.err.println(&quot;Exception=C2=A0 =3D &gt; &quot; + e.get=
Message());<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 e.printStackTrace();<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 }<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 }<br>
<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 private static void unionMessageStreams(DataStr=
eam&lt;String&gt; msgDataStream1,<br>
DataStream&lt;String&gt; msgDataStream2) {<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 try {<br>
<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 DataStream&lt;String&gt; ds =3D msgDataStream1.union(msgDataStre=
am2);<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 ds.print();<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 } catch (Exception =
e) {<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 System.err.println(&quot;Exception in union Message Streams () =
=3D &gt; &quot; +<br>
e.getMessage());<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 }<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 }<br>
<br>
Thanks<br>
<br>
<br>
<br>
--<br>
View this message in context: <a href=3D"http://apache-flink-user-mailing-l=
ist-archive.2336050.n4.nabble.com/Flink-Data-Stream-Union-tp3169p3196.html"=
 rel=3D"noreferrer" target=3D"_blank">http://apache-flink-user-mailing-list=
-archive.2336050.n4.nabble.com/Flink-Data-Stream-Union-tp3169p3196.html</a>=
<br>
<div class=3D"HOEnZb"><div class=3D"h5">Sent from the Apache Flink User Mai=
ling List archive. mailing list archive at Nabble.com.<br>
</div></div></blockquote></div><br></div>

--f46d043c807a5df11a05229d5e69--