From a2222d4fa0de4200ef2aa524f63d61d3cb65c285 Mon Sep 17 00:00:00 2001
From: cyruslo <710058301@qq.com>
Date: Sun, 28 Jul 2024 23:17:41 +0800
Subject: [PATCH] fixed: internalBatchSend issue(#100)

Signed-off-by: cyruslo <710058301@qq.com>
---
 opengemini/write.go | 8 ++++++++
 1 file changed, 8 insertions(+)

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