Re: [External] Re: Memory Issue When Running Beam On Flink

2020-08-24 Thread Maximilian Michels
I'd suggest a modified option (2) which does not use a timer to perform the cleanup (as mentioned, this will cause problems with migrating state). Instead, whenever we receive a watermark which closes the global window, we enumerate all keys and cleanup the associated state. This is the

Beam Dependency Check Report (2020-08-24)

2020-08-24 Thread Apache Jenkins Server
ERROR: File 'src/build/dependencyUpdates/beam-dependency-check-report.html' does not exist