Hello,
I am currently updating from Beam 2.25.0 to Beam 2.27.0 and from Flink
1.10.3 to Flink 1.11.3.
My pipeline does read from 2 Kafka topics and windowing them via:
Window.>into(
FixedWindows.of(Duration.standardMinutes(1)))
.withAllowedLateness(Duration.standa
Hey Nir,
Could you elaborate on how your setup looks? Are you using Java or Python?
Which Flink version? Is the cluster running on K8s? Do you use the portable
runner or the classic one?
On Mon, Feb 8, 2021 at 5:41 PM Joseph Zack wrote:
> unsubscribe
>
> On Mon, Feb 8, 2021 at 5:06 AM Nir Gazit
Is there a recorded version of this presentation?
For the ones that missed it.
On Thu, Feb 11, 2021 at 6:06 PM Carlos Camacho
wrote:
>
> Hi everyone,
> This is a friendly reminder to join the UX Research Findings Readout.
>
> We are live now! Join us: https://meet.google.com/xfc-majk-byk
>
> --
