change

pingcap · Jan 5, 2024 · d563285 · d563285
1 parent 9ff6d40
commit d563285
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/br/pkg/lightning/config/config.go b/br/pkg/lightning/config/config.go
@@ -332,6 +332,11 @@ func (l *Lightning) adjust(i *TikvImporter) {
 		if len(l.MetaSchemaName) == 0 {
 			l.MetaSchemaName = defaultMetaSchemaName
 		}
+		// RegionConcurrency > NumCPU is meaningless.
+		cpuCount := runtime.NumCPU()
+		if l.RegionConcurrency > cpuCount {
+			l.RegionConcurrency = cpuCount
+		}
 	}
 }