Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
MIME-Version: 1.0
In-Reply-To: <1497960046109-13853.post@n4.nabble.com>
References: <CA+YaHHUta7yaKYOmxRZrLV6kaKAhZRotq=BmZGmbgy8suqDEjA@mail.gmail.com>
 <1496754612762-13509.post@n4.nabble.com> <1496754855739-13512.post@n4.nabble.com>
 <1496755032775-13513.post@n4.nabble.com> <CA+YaHHXPrhv4oygGLTkkj_7vTaBfkrBxHSs+cnhHXt93JETv5A@mail.gmail.com>
 <1496758638969-13523.post@n4.nabble.com> <CA+YaHHX7BfkUBYOUPw3xjSvTmPHd4myvBuRDVpkdvTiv-pTMig@mail.gmail.com>
 <1496849596754-13567.post@n4.nabble.com> <1496928932696-13591.post@n4.nabble.com>
 <CA+YaHHWMCGK=1Am2+0TNiYSoet5WQVp9iSKLHFvRuzuwe74mDg@mail.gmail.com> <1497960046109-13853.post@n4.nabble.com>
From: Dawid Wysakowicz <wysakowicz.dawid@gmail.com>
Date: Tue, 20 Jun 2017 14:21:17 +0200
Message-ID: <CA+YaHHUeRxPUdNiUN=7_hhpXd_5a+MO3TU1Xbs6X_x0WjYKy_A@mail.gmail.com>
Subject: Re: Queries regarding FlinkCEP
To: Biplob Biswas <revolutionisme@gmail.com>
Cc: user <user@flink.apache.org>
Content-Type: multipart/alternative; boundary="94eb2c06abb8d46a2c0552634964"
archived-at: Tue, 20 Jun 2017 12:21:23 -0000

--94eb2c06abb8d46a2c0552634964
Content-Type: text/plain; charset="UTF-8"

For example if there is no events in one of the partitions the partition
will always generate Watermark(Long.MIN_VALUE) which will result in
Watermark not being advanced. There is open JIRA to improve such
situations: FLINK-5479 <https://issues.apache.org/jira/browse/FLINK-5479>.

Z pozdrowieniami! / Cheers!

Dawid Wysakowicz

*Data/Software Engineer*

Skype: dawid_wys | Twitter: @OneMoreCoder

<http://getindata.com/>

2017-06-20 14:00 GMT+02:00 Biplob Biswas <revolutionisme@gmail.com>:

> Hi dawid,
>
> Yes I am reading from multiple topics and yes a few topics have multiple
> partitions, not all of them.
>
> But I didn't understand the concept of stalled partition.
>
>
>
> --
> View this message in context: http://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Queries-regarding-FlinkCEP-
> tp13454p13853.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>

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

<div dir=3D"ltr">For example if there is no events in one of the partitions=
 the partition will always generate Watermark(Long.MIN_VALUE) which will re=
sult in Watermark not being advanced. There is open JIRA to improve such si=
tuations:=C2=A0<a href=3D"https://issues.apache.org/jira/browse/FLINK-5479"=
>FLINK-5479</a>.</div><div class=3D"gmail_extra"><br clear=3D"all"><div><di=
v class=3D"gmail_signature" data-smartmail=3D"gmail_signature"><div dir=3D"=
ltr"><p dir=3D"ltr" style=3D"font-size:12.8px;color:rgb(136,136,136);line-h=
eight:1.38;margin-top:0pt;margin-bottom:0pt"><span style=3D"font-family:Ari=
al;color:rgb(77,77,77);vertical-align:baseline;white-space:pre-wrap"><font =
size=3D"2">Z pozdrowieniami! / Cheers!</font></span></p><br style=3D"font-s=
ize:12.8px;color:rgb(136,136,136)"><p dir=3D"ltr" style=3D"font-size:12.8px=
;color:rgb(136,136,136);line-height:1.38;margin-top:0pt;margin-bottom:0pt">=
<span style=3D"font-size:13.3333px;font-family:Arial;color:rgb(61,133,198);=
font-weight:bold;vertical-align:baseline;white-space:pre-wrap">Dawid Wysako=
wicz</span></p><p dir=3D"ltr" style=3D"font-size:12.8px;color:rgb(136,136,1=
36);line-height:1.38;margin-top:0pt;margin-bottom:0pt"><span style=3D"font-=
size:13.3333px;font-family:Arial;color:rgb(102,102,102);vertical-align:base=
line;white-space:pre-wrap"><b>Data/Software Engineer</b></span></p><p dir=
=3D"ltr" style=3D"font-size:12.8px;color:rgb(136,136,136);margin-top:0pt;ma=
rgin-bottom:0pt"><span style=3D"line-height:1.38;color:rgb(102,102,102);fon=
t-family:Arial;font-size:13.3333px;white-space:pre-wrap">Skype: dawid_wys |=
 Twitter: @OneMoreCoder</span></p><p dir=3D"ltr" style=3D"font-size:12.8px;=
color:rgb(136,136,136);margin-top:0pt;margin-bottom:0pt"><a href=3D"http://=
getindata.com/" style=3D"color:rgb(17,85,204);font-size:12.8px" target=3D"_=
blank"><img src=3D"https://lh3.googleusercontent.com/UAZ_gKrwkrWHfPuN2KZKwo=
nhDCD5USarteFNDw7oWDBoaOuVJABphipZJocSmqYGIvuD9qUrF2_vTmGLzZtv0FZMPzmDpeInf=
E3MzGV4YQR_6VLsDdJcUX0nmsvVyX7RmICK4_U" width=3D"96" height=3D"16" style=3D=
"font-size:12.8px;border:none"></a></p></div></div></div>
<br><div class=3D"gmail_quote">2017-06-20 14:00 GMT+02:00 Biplob Biswas <sp=
an dir=3D"ltr">&lt;<a href=3D"mailto:revolutionisme@gmail.com" target=3D"_b=
lank">revolutionisme@gmail.com</a>&gt;</span>:<br><blockquote class=3D"gmai=
l_quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left=
:1ex">Hi dawid,<br>
<br>
Yes I am reading from multiple topics and yes a few topics have multiple<br=
>
partitions, not all of them.<br>
<br>
But I didn&#39;t understand the concept of stalled partition.<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/Queries-regarding-FlinkCEP-tp13454p13853.=
html" rel=3D"noreferrer" target=3D"_blank">http://apache-flink-user-<wbr>ma=
iling-list-archive.2336050.<wbr>n4.nabble.com/Queries-<wbr>regarding-FlinkC=
EP-<wbr>tp13454p13853.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>

--94eb2c06abb8d46a2c0552634964--