diff --git a/configs/milvus.yaml b/configs/milvus.yaml index 8e6d80151d..239c9a7abe 100644 --- a/configs/milvus.yaml +++ b/configs/milvus.yaml @@ -259,6 +259,9 @@ indexCoord: gc: interval: 600 # gc interval in seconds + scheduler: + interval: 1000 # scheduler interval in Millisecond + indexNode: port: 21121 enableDisk: true # enable index node build disk vector index diff --git a/internal/datacoord/index_builder.go b/internal/datacoord/index_builder.go index e6cb946d94..032fad3dc3 100644 --- a/internal/datacoord/index_builder.go +++ b/internal/datacoord/index_builder.go @@ -97,7 +97,7 @@ func newIndexBuilder(ctx context.Context, metaTable *meta, nodeManager *IndexNod meta: metaTable, tasks: make(map[int64]indexTaskState), notifyChan: make(chan struct{}, 1), - scheduleDuration: time.Second, + scheduleDuration: Params.DataCoordCfg.IndexTaskSchedulerInterval.GetAsDuration(time.Millisecond), policy: defaultBuildIndexPolicy, nodeManager: nodeManager, chunkManager: chunkManager, diff --git a/internal/util/paramtable/component_param.go b/internal/util/paramtable/component_param.go index 38629a273a..af1fb83e54 100644 --- a/internal/util/paramtable/component_param.go +++ b/internal/util/paramtable/component_param.go @@ -1399,10 +1399,11 @@ type dataCoordConfig struct { GCDropTolerance ParamItem `refreshable:"false"` EnableActiveStandby ParamItem `refreshable:"false"` - BindIndexNodeMode ParamItem `refreshable:"false"` - IndexNodeAddress ParamItem `refreshable:"false"` - WithCredential ParamItem `refreshable:"false"` - IndexNodeID ParamItem `refreshable:"false"` + BindIndexNodeMode ParamItem `refreshable:"false"` + IndexNodeAddress ParamItem `refreshable:"false"` + WithCredential ParamItem `refreshable:"false"` + IndexNodeID ParamItem `refreshable:"false"` + IndexTaskSchedulerInterval ParamItem `refreshable:"false"` MinSegmentNumRowsToEnableIndex ParamItem `refreshable:"true"` } @@ -1639,6 +1640,12 @@ func (p *dataCoordConfig) init(base *BaseTable) { DefaultValue: "0", } p.IndexNodeID.Init(base.mgr) + p.IndexTaskSchedulerInterval = ParamItem{ + Key: "indexCoord.scheduler.interval", + Version: "2.0.0", + DefaultValue: "1000", + } + p.IndexTaskSchedulerInterval.Init(base.mgr) } // /////////////////////////////////////////////////////////////////////////////