Understanding distributed memory garbage collection

General Usage
2

This is a bug.

Edit: A workaround (applicable in the context of this MWE only) till it is fixed is to finalize the ref in the worker function as soon as it is fetched.

function workerFunction( sigmaRef::Union{Future,RemoteChannel} )

   sigma = fetch(sigmaRef)
   finalize(sigmaRef)                 # <---- Finalize after fetching in the worker func.
   println(sum(sigma))

   return true
end

I have tested with the workaround on 0.6.2

Would you be able to open an issue on Github for this ?

1 Like