Re: [External] Re: Memory Issue When Running Beam On Flink
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 clean
Beam Dependency Check Report (2020-08-24)
ERROR: File 'src/build/dependencyUpdates/beam-dependency-check-report.html' does not exist