diff --git a/src/meta/src/barrier/worker.rs b/src/meta/src/barrier/worker.rs index c2fa4e49676cc..02334ef103a19 100644 --- a/src/meta/src/barrier/worker.rs +++ b/src/meta/src/barrier/worker.rs @@ -413,6 +413,7 @@ impl CompletingTask { } } } + *self = Self::new(); } }