Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
MIME-Version: 1.0
From: Yunus Olgun <yunolgun@gmail.com>
Date: Mon, 28 Aug 2017 17:09:49 +0200
Message-ID: <CAJ5jvib+XjcR8zhXGUwXdA4g+_m4YdxV2q59jBEK0EWw7ufxMQ@mail.gmail.com>
Subject: CoGroupedStreams.WithWindow sideOutputLateData and allowedLateness
To: user@flink.apache.org
Content-Type: multipart/alternative; boundary="f403045fde40a36d6d0557d1afb6"
archived-at: Mon, 28 Aug 2017 15:10:06 -0000

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

Hi,

WindowedStream has sideOutputLateData and allowedLateness methods to handle
late data. A similar functionality at CoGroupedStreams would have been
nice. As it is, it silently ignores late data and it is error-prone.

- Is there a reason it does not exist?
- Any suggested workaround?

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

<div dir=3D"ltr">Hi,<div><br></div><div>WindowedStream has sideOutputLateDa=
ta and=C2=A0allowedLateness methods to handle late data. A similar function=
ality at=C2=A0CoGroupedStreams would have been nice. As it is, it silently =
ignores late data and it is error-prone.</div><div><br></div><div>- Is ther=
e a reason it does not exist?</div><div>- Any suggested workaround?</div></=
div>

--f403045fde40a36d6d0557d1afb6--