Re: TextIO. Writing late files

2020-05-10 Thread Reuven Lax
Pane info is supposed to be preserved across transforms. If the Fink runner does not, than I believe that is a bug. On Sat, May 9, 2020 at 11:22 PM Jozef Vilcek wrote: > I am using FileIO and I do observe the drop of pane info information on > Flink runner too. It was mentioned in this thread: >

Register now for the Beam Summit 2020!

2020-05-10 Thread Matthias Baetens
Hi all, We are happy to share some more information on the *Beam Summit 2020* that will take place on the *world wide web* this time around :) 🎫 You can now *register on Crowdcast *, where the conference will take place. 💸 Want to help to make the Beam Summit ev

How to test custom window with inOnTimePane assertion?

2020-05-10 Thread Marcin Kuthan
Hi Next step in my experiments with Beam: custom windowing. It works (at least on direct runner) but it looks that my custom window implementation is somehow not compatible with inOnTimePane assertion. Without paneinfo assertion unit test passes, with inOnTimePane assertion the expected element i