lint

pingcap · Sep 15, 2023 · 65b43b4 · 65b43b4
1 parent b66650f
commit 65b43b4
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 4 deletions.
diff --git a/br/pkg/lightning/backend/local/local.go b/br/pkg/lightning/backend/local/local.go
@@ -1690,7 +1690,8 @@ func (local *Backend) GetImportedKVCount(engineUUID uuid.UUID) int64 {
 }
 
 // GetExternalEngineKVStatistics returns kv statistics of some engine.
-func (local *Backend) GetExternalEngineKVStatistics(engineUUID uuid.UUID) (int64, int64) {
+func (local *Backend) GetExternalEngineKVStatistics(engineUUID uuid.UUID) (
+	totalKVSize int64, totalKVCount int64) {
 	v, ok := local.externalEngine[engineUUID]
 	if !ok {
 		// we get it after import, but before clean up, so this should not happen

diff --git a/disttask/framework/dispatcher/dispatcher.go b/disttask/framework/dispatcher/dispatcher.go
@@ -119,7 +119,7 @@ func NewBaseDispatcher(ctx context.Context, taskMgr *storage.TaskManager, server
 }
 
 // Init implements the Dispatcher interface.
-func (d *BaseDispatcher) Init() error {
+func (*BaseDispatcher) Init() error {
 	return nil
 }
 

diff --git a/executor/importer/chunk_process.go b/executor/importer/chunk_process.go
@@ -385,7 +385,7 @@ func (w *IndexRouteWriter) AppendRows(ctx context.Context, _ []string, rows enco
 }
 
 // IsSynced implements backend.EngineWriter interface.
-func (w *IndexRouteWriter) IsSynced() bool {
+func (*IndexRouteWriter) IsSynced() bool {
 	return true
 }
 

diff --git a/executor/importer/table_import.go b/executor/importer/table_import.go
@@ -148,7 +148,7 @@ func GetCachedKVStoreFrom(pdAddr string, tls *common.TLS) (tidbkv.Storage, error
 }
 
 // GetRegionSplitSizeKeys gets the region split size and keys from PD.
-func GetRegionSplitSizeKeys(ctx context.Context) (int64, int64, error) {
+func GetRegionSplitSizeKeys(ctx context.Context) (regionSplitSize int64, regionSplitKeys int64, err error) {
 	tidbCfg := tidb.GetGlobalConfig()
 	hostPort := net.JoinHostPort("127.0.0.1", strconv.Itoa(int(tidbCfg.Status.StatusPort)))
 	tls, err := common.NewTLS(