Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
Content-Type: text/plain; charset=us-ascii
Mime-Version: 1.0 (Mac OS X Mail 9.0 \(3094\))
Subject: Re: Flink Data Stream Union
From: Aljoscha Krettek <aljoscha.krettek@gmail.com>
In-Reply-To: 
 <CA+ybEFg138hLpyyjMd0ENSxHHBOjViyt1=AqSBxG1-11onOdZA@mail.gmail.com>
Date: Wed, 21 Oct 2015 16:39:53 +0200
Content-Transfer-Encoding: quoted-printable
Message-Id: <C2402B04-9145-4025-8899-5C592DCE907D@gmail.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>
 <CAC27z=OTPc2CqGTOjhMMXTHTXtyeA0mmYLGtx9i3wKw54OF6Qg@mail.gmail.com>
 <76AFC42B-DE46-47E1-B4D2-E677085174D5@gmail.com>
 <CA+ybEFjnx4tkpR_v8h95=10YqR5MZuguTN7rsCjSqncCQ+C+vA@mail.gmail.com>
 <04E307A1-AB61-4C55-A0E3-CA7C855B9F3A@gmail.com>
 <CA+ybEFg138hLpyyjMd0ENSxHHBOjViyt1=AqSBxG1-11onOdZA@mail.gmail.com>
To: user@flink.apache.org

So does the filter maybe filter out everything?
> On 21 Oct 2015, at 16:18, Gayu <gaayuu@gmail.com> wrote:
>=20
> Yes, exactly.=20
>=20
> On Wed, Oct 21, 2015 at 10:17 AM, Aljoscha Krettek =
<aljoscha.krettek@gmail.com> wrote:
> So it is received in the filter but the print afterwards does not =
print?
> > On 21 Oct 2015, at 15:49, Gayu <gaayuu@gmail.com> wrote:
> >
> > The data does arrive in the second port and i am able to see that in =
the filter class received.
> > It happens only on specific machine on which i run the code.
> >
> >
> > Yes, i did forget to post here, but my program calls the =
unionMessageStreams()
> >
> > On Wed, Oct 21, 2015 at 9:39 AM, Aljoscha Krettek =
<aljoscha.krettek@gmail.com> wrote:
> > Hi Gayu,
> > could it be that no data ever arrives on the second input stream? Or =
that the filter filters out all messages?
> >
> > Also, in the example you posted you forgot to call =
unionMessageStreams().
> >
> > Cheers,
> > Aljoscha
> >
> > > On 21 Oct 2015, at 15:29, Till Rohrmann <trohrmann@apache.org> =
wrote:
> > >
> > > 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 =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 =
archive at Nabble.com.
> > >
> >
> >
> >
> >
> > --
> > Gayu
>=20
>=20
>=20
>=20
> --=20
> Gayu