Skip to content

Commit

Permalink
fix comments
Browse files Browse the repository at this point in the history
  • Loading branch information
D3Hunter committed Apr 7, 2023
1 parent c0dbaee commit 66d0c78
Showing 1 changed file with 12 additions and 9 deletions.
21 changes: 12 additions & 9 deletions executor/importer/table_import.go
Original file line number Diff line number Diff line change
Expand Up @@ -107,22 +107,25 @@ func newTableImporter(ctx context.Context, e *LoadDataController) (ti *tableImpo
}

backendConfig := local.BackendConfig{
PDAddr: tidbCfg.Path,
LocalStoreDir: dir,
MaxConnPerStore: config.DefaultRangeConcurrency,
ConnCompressType: config.CompressionNone,
WorkerConcurrency: config.DefaultRangeConcurrency * 2,
KVWriteBatchSize: config.KVWriteBatchSize,
PDAddr: tidbCfg.Path,
LocalStoreDir: dir,
MaxConnPerStore: config.DefaultRangeConcurrency,
ConnCompressType: config.CompressionNone,
WorkerConcurrency: config.DefaultRangeConcurrency * 2,
KVWriteBatchSize: config.KVWriteBatchSize,
// todo: local backend report error when the sort-dir already exists & checkpoint disabled.
// set to false when we fix it.
CheckpointEnabled: true,
MemTableSize: int(config.DefaultEngineMemCacheSize),
LocalWriterMemCacheSize: int64(config.DefaultLocalWriterMemCacheSize),
ShouldCheckTiKV: true,
DupeDetectEnabled: false,
DuplicateDetectOpt: local.DupDetectOpt{ReportErrOnDup: false},
StoreWriteBWLimit: 0,
ShouldCheckWriteStall: false,
MaxOpenFiles: int(util.GenRLimit()),
KeyspaceName: keySpaceName,
// todo: we can set it false when we support switch import mode.
ShouldCheckWriteStall: true,
MaxOpenFiles: int(util.GenRLimit()),
KeyspaceName: keySpaceName,
}

tableMeta := &mydump.MDTableMeta{
Expand Down

0 comments on commit 66d0c78

Please sign in to comment.