clean task info (#79)

clean task memory record after task execute finished
oceanbase · Sep 27, 2023 · 33ef18a · 33ef18a
1 parent 17a756b
commit 33ef18a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/resource/coordinator.go b/pkg/resource/coordinator.go
@@ -127,6 +127,7 @@ func (c *Coordinator) executeTaskFlow(f *task.TaskFlow) {
 		c.Logger.Info("Task failed, back to initial status")
 		c.Manager.HandleFailure()
 	}
+	c.cleanTaskResultMap(f)
 	// Coordinate finished
 }