Minor changes after testing by PR77 (#81)

CentaurusInfra · Jul 13, 2022 · 4622bdc · 4622bdc
1 parent 332db6d
commit 4622bdc
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 4 deletions.
diff --git a/resource-management/pkg/aggregrator/aggregator.go b/resource-management/pkg/aggregrator/aggregator.go
@@ -86,7 +86,6 @@ func (a *Aggregator) Run() (err error) {
 
 			klog.V(3).Infof("Starting loop pulling nodes from region: %v", a.urls[i])
 			for {
-				klog.V(9).Infof("Wait for 100 milisecond...")
 				time.Sleep(100 * time.Millisecond)
 
 				// Call the Pull methods
@@ -149,8 +148,6 @@ func (a *Aggregator) initPullOrSubsequentPull(c *ClientOfRRM, batchLength uint64
 		path = httpPrefix + c.BaseURL + "/resources/subsequentpull"
 	}
 
-	klog.V(9).Infof("CRV : (%v)", crv)
-
 	bytes, _ := json.Marshal(PullDataFromRRM{BatchLength: batchLength, CRV: crv.Copy()})
 	req, err := http.NewRequest(http.MethodGet, path, strings.NewReader((string(bytes))))
 	if err != nil {

diff --git a/resource-management/test/e2e/singleClientTest.go b/resource-management/test/e2e/singleClientTest.go
@@ -212,7 +212,7 @@ func watchNodes(client rmsclient.RmsInterface, clientId string, crv types.Transi
 func logIfProlonged(record *event.NodeEvent, t time.Time, ws *stats.WatchStats) {
 	d := t.Sub(record.Node.LastUpdatedTime)
 	if d > stats.LongWatchThreshold {
-		klog.Infof("Prolonged watch node from server: %v, %v", record, *record.Node)
+		klog.Infof("Prolonged watch node from server: %v, %v with time (%v)", record, *record.Node, d)
 		ws.NumberOfProlongedItems++
 	}
 }