xg

tagservice/src/historytask.go

@@ -388,7 +388,7 @@ func EsHistoryData() {
 		}
 		wg.Wait()
 		client.ClearScroll().ScrollId(scrollId).Do() //清理游标
-		//time.Sleep(5 * time.Second)
+		time.Sleep(5 * time.Second)
 		log.Println("Result Data Count：", numDocs, "	Tags Data Count：", numTags)
 	} else {
 		log.Println("Es Scroll Find Error：", err)

tagservice/src/newtask.go

@@ -462,7 +462,7 @@ func (t *Task) RunEs() {
 		}
 		t.Wg.Wait()
 		client.ClearScroll().ScrollId(scrollId).Do() //清理游标
-		//time.Sleep(5 * time.Second)
+		time.Sleep(5 * time.Second)
 		log.Println("Result Data Count：", numDocs, "	Tags Data Count：", numTags)
 		t.StartId = endId //替换id
 		setid := map[string]interface{}{