clean_stale_shared_memory# streaming.base.util.clean_stale_shared_memory()[source]# Clean up all the leaked shared memory. In case of a distributed run, clean up happens on local rank 0 while other local ranks wait for the local rank 0 to finish.