owner: Update the interval of printing log (pingcap#4485)

owner/manager.go

@@ -31,6 +31,11 @@ import (
 	goctx "golang.org/x/net/context"
 )
 
+const (
+	newSessionRetryInterval = 200 * time.Millisecond
+	logIntervalCnt          = int(3 * time.Second / newSessionRetryInterval)
+)
+
 // Manager is used to campaign the owner and manage the owner information.
 type Manager interface {
 	// ID returns the ID of the manager.
@@ -120,6 +125,7 @@ func setManagerSessionTTL() error {
 func NewSession(ctx goctx.Context, logPrefix string, etcdCli *clientv3.Client, retryCnt, ttl int) (*concurrency.Session, error) {
 	var err error
 	var etcdSession *concurrency.Session
+	failedCnt := 0
 	for i := 0; i < retryCnt; i++ {
 		if isContextDone(ctx) {
 			return etcdSession, errors.Trace(ctx.Err())
@@ -130,8 +136,11 @@ func NewSession(ctx goctx.Context, logPrefix string, etcdCli *clientv3.Client, r
 		if err == nil {
 			break
 		}
-		log.Warnf("%s failed to new session, err %v", logPrefix, err)
-		time.Sleep(200 * time.Millisecond)
+		if failedCnt%logIntervalCnt == 0 {
+			log.Warnf("%s failed to new session, err %v", logPrefix, err)
+		}
+		time.Sleep(newSessionRetryInterval)
+		failedCnt++
 	}
 	return etcdSession, errors.Trace(err)
 }

plan/join_reorder.go

@@ -47,7 +47,7 @@ func findColumnIndexByGroup(groups []LogicalPlan, col *expression.Column) int {
 			return i
 		}
 	}
-	log.Errorf("Unknown columns %s, from id %s, position %d", col, col.FromID, col.Position)
+	log.Errorf("Unknown columns %s, from id %d, position %d", col, col.FromID, col.Position)
 	return -1
 }