diff --git a/server/src/es/insert.go b/server/src/es/insert.go index c24dd70..bb12197 100644 --- a/server/src/es/insert.go +++ b/server/src/es/insert.go @@ -25,9 +25,10 @@ func Insert(d *pb.EsMetrics) { index := indexName(uint32(d.Ts / 1000)) - _, err = theClient.Index(index, bytes.NewReader(ab)) + re, err := theClient.Index(index, bytes.NewReader(ab)) if err != nil { zj.W(`insert fail:`, err) return } + re.Body.Close() } diff --git a/server/src/es/test.go b/server/src/es/test.go index 93e76cb..a5d2a88 100644 --- a/server/src/es/test.go +++ b/server/src/es/test.go @@ -64,6 +64,6 @@ func Test() { } Insert(d) - time.Sleep(time.Second / 2) + time.Sleep(time.Second / 10) } }