Re: [VOTE] Release 2.33.0, release candidate 2

2021-10-06 Thread Lukáš Drbal
+1 (non-binding) validated by running our pipelines (Java SDK, Flink Runner, Flink 1.13.2) Thanks! On Mon, Oct 4, 2021 at 11:27 PM Udi Meiri wrote: > Hi everyone, > Please review and vote on the release candidate #2 for the version 2.33.0, > as follows: > [ ] +1, Approve the release > [ ] -1,

Flink non-portable runner: unable to restore savepoint in 2.32.0

2021-09-03 Thread Lukáš Drbal
Hi, We are using beam + non-portable flink runner and now we are trying to upgrade from 2.31.0 to 2.32.0. Savepoint restore failed with: Caused by: java.lang.IllegalStateException: Could not Java-deserialize TypeSerializer while restoring checkpoint metadata for serializer snapshot

Monthly calendar window in SQL DSL

2019-02-08 Thread Lukáš Drbal
Hi everyone, Is there any way how to use monthly calendar window in SQL DSL? Maybe I miss something but i don't see any way for this. Is that correct? Thanks. Currently I can create window before running SQL transform and it's just a basic test so i'm fine with: