diff --git a/ompi/mca/osc/ucx/osc_ucx_component.c b/ompi/mca/osc/ucx/osc_ucx_component.c index 955857d974..3aa6424017 100644 --- a/ompi/mca/osc/ucx/osc_ucx_component.c +++ b/ompi/mca/osc/ucx/osc_ucx_component.c @@ -804,6 +804,8 @@ int ompi_osc_ucx_free(struct ompi_win_t *win) { ucp_worker_progress(mca_osc_ucx_component.ucp_worker); } + opal_common_ucx_worker_flush(mca_osc_ucx_component.ucp_worker); + ret = module->comm->c_coll->coll_barrier(module->comm, module->comm->c_coll->coll_barrier_module);