Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
MIME-Version: 1.0
In-Reply-To: <1490271383416-12356.post@n4.nabble.com>
References: <1490258838339-12337.post@n4.nabble.com> <CAKDV8W4bYbYbe43pS-vZrUAwMxrd3c_TPqTFxVQ5q+cTXzUUPA@mail.gmail.com>
 <1490271383416-12356.post@n4.nabble.com>
From: Yassine MARZOUGUI <y.marzougui@mindlytix.com>
Date: Fri, 24 Mar 2017 11:23:56 +0100
Message-ID: <CAKDV8W4ZZgjAoGM6FFaF_1hkpdwMGtauwDRd9HXse6NxuBQMpw@mail.gmail.com>
Subject: Re: Windows emit results at the end of the stream
To: user@flink.apache.org
Content-Type: multipart/alternative; boundary=f403045f587427841d054b7764dd
archived-at: Fri, 24 Mar 2017 10:24:02 -0000

--f403045f587427841d054b7764dd
Content-Type: text/plain; charset=UTF-8

Hi Sonex,

I don't known well Scala as I know Java, but I guess it should be correct
if no error is raised.
The behaviour you described seems wierd to me and should not happen. I'm
unfortunately unable to identify an apparent cause, maybe someone in the
mailing list can shed a light on that.

Best,
Yassine

2017-03-23 13:16 GMT+01:00 Sonex <alfredjenssen@gmail.com>:

> Thank you for your response Yassine,
>
> I forgot to mention that I use the Scala API. In Scala the equivalent code
> is:
>
> val inputFormat = new TextInputFormat(new Path("file/to/read.txt"))
> env.readFile(inputFormat,"file/to/read.txt",
> FileProcessingMode.PROCESS_CONTINUOUSLY,10000L)
>
> Am I correct?
>
> But I noticed a weird behavior now. Sometimes, it never starts to process
> the elements of the file and sometimes it stops at the middle of the file
> without processing the rest of it. Why does that happen?
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Windows-emit-
> results-at-the-end-of-the-stream-tp12337p12356.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>

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

<div dir=3D"ltr"><div>Hi Sonex,</div><div><br></div>I don&#39;t known well =
Scala as I know Java, but I guess it should be correct if no error is raise=
d.<div>The behaviour you described seems wierd to me and should not happen.=
 I&#39;m unfortunately unable to identify an apparent=C2=A0cause, maybe som=
eone in the mailing list can shed a light on that.</div><div><br></div><div=
>Best,</div><div>Yassine</div></div><div class=3D"gmail_extra"><br><div cla=
ss=3D"gmail_quote">2017-03-23 13:16 GMT+01:00 Sonex <span dir=3D"ltr">&lt;<=
a href=3D"mailto:alfredjenssen@gmail.com" target=3D"_blank">alfredjenssen@g=
mail.com</a>&gt;</span>:<br><blockquote class=3D"gmail_quote" style=3D"marg=
in:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">Thank you for yo=
ur response Yassine,<br>
<br>
I forgot to mention that I use the Scala API. In Scala the equivalent code<=
br>
is:<br>
<br>
val inputFormat =3D new TextInputFormat(new Path(&quot;file/to/read.txt&quo=
t;))<br>
env.readFile(inputFormat,&quot;<wbr>file/to/read.txt&quot;,<br>
FileProcessingMode.PROCESS_<wbr>CONTINUOUSLY,10000L)<br>
<br>
Am I correct?<br>
<br>
But I noticed a weird behavior now. Sometimes, it never starts to process<b=
r>
the elements of the file and sometimes it stops at the middle of the file<b=
r>
without processing the rest of it. Why does that happen?<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/Windows-emit-results-at-the-end-of-the-st=
ream-tp12337p12356.html" rel=3D"noreferrer" target=3D"_blank">http://apache=
-flink-user-<wbr>mailing-list-archive.2336050.<wbr>n4.nabble.com/Windows-em=
it-<wbr>results-at-the-end-of-the-<wbr>stream-tp12337p12356.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>

--f403045f587427841d054b7764dd--