adjust log and check timer

absolute8511 · Aug 17, 2017 · 3b93093 · 3b93093
1 parent 3da74ba
commit 3b93093
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/cluster/datanode_coord/dn_schema_coord.go b/cluster/datanode_coord/dn_schema_coord.go
@@ -12,7 +12,7 @@ import (
 func (dc *DataCoordinator) doSyncSchemaInfo(localNamespace *node.NamespaceNode,
 	indexSchemas map[string]*common.IndexSchema) {
 
-	cluster.CoordLog().Infof("namespace %v checking schema sync: %v",
+	cluster.CoordLog().Debugf("namespace %v checking schema sync: %v",
 		localNamespace.FullName(), len(indexSchemas))
 	for table, tindexes := range indexSchemas {
 		localIndexSchema, err := localNamespace.Node.GetIndexSchema(table)

diff --git a/cluster/pdnode_coord/pd_coordinator.go b/cluster/pdnode_coord/pd_coordinator.go
@@ -435,7 +435,7 @@ func (pdCoord *PDCoordinator) triggerCheckNamespaces(namespace string, part int,
 // check if replication is enough
 // check any unexpected state.
 func (pdCoord *PDCoordinator) checkNamespaces(monitorChan chan struct{}) {
-	ticker := time.NewTicker(time.Second * 30)
+	ticker := time.NewTicker(time.Second * 60)
 	waitingMigrateNamespace := make(map[string]map[int]time.Time)
 	defer func() {
 		ticker.Stop()

diff --git a/cluster/pdnode_coord/pd_schema_coord.go b/cluster/pdnode_coord/pd_schema_coord.go
@@ -83,7 +83,7 @@ func (pdCoord *PDCoordinator) doSchemaCheck() {
 				isReady = false
 				break
 			}
-			cluster.CoordLog().Infof("namespace %v got schema : %v", common.GetNsDesp(ns, pid),
+			cluster.CoordLog().Debugf("namespace %v got schema : %v", common.GetNsDesp(ns, pid),
 				len(schemas))
 			allPartsSchema[pid] = schemas
 		}