diff --git a/opengemini/write.go b/opengemini/write.go
index 8a1c1d8..9948e1d 100644
--- a/opengemini/write.go
+++ b/opengemini/write.go
@@ -27,6 +27,11 @@ type sendBatchWithCB struct {
 	callback WriteCallback
 }
 
+func (s *sendBatchWithCB) Clear() {
+	s.point = nil
+	s.callback(fmt.Errorf("sendBatchWithCB timeout"))
+}
+
 type dbRp struct {
 	db string
 	rp string
@@ -129,6 +134,9 @@ func (c *client) internalBatchSend(ctx context.Context, database string, rp stri
 		select {
 		case <-ctx.Done():
 			ticker.Stop()
+			for record := range resource {
+				record.Clear()
+			}
 			return
 		case <-ticker.C:
 			needFlush = true