admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-07 19:31:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix watch event timeout when IO Pool busy(#23293) (#23388)

Browse Source 
Signed-off-by: aoiasd <zhicheng.yue@zilliz.com>
This commit is contained in:
aoiasd 2023-04-12 18:56:29 +08:00 committed by GitHub
parent 19338437d4
commit c64e88099b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
configs/milvus.yaml
View File

@ -280,7 +280,7 @@ dataCoord:
enableActiveStandby: false # Enable active-standby
channel:
watchTimeoutInterval: 30 # Timeout on watching channels (in seconds). Datanode tickler update watch progress will reset timeout timer.
watchTimeoutInterval: 120 # Timeout on watching channels (in seconds). Datanode tickler update watch progress will reset timeout timer.
balanceSilentDuration: 300 # The duration before the channelBalancer on datacoord to run
balanceInterval: 360 #The interval for the channelBalancer on datacoord to check balance status

7
internal/datanode/data_sync_service.go
View File

@ -193,6 +193,9 @@ func (dsService *dataSyncService) initNodes(vchanInfo *datapb.VchannelInfo, tick
return err
}
//tickler will update addSegment progress to watchInfo
tickler.watch()
defer tickler.stop()
futures := make([]*concurrency.Future, 0, len(unflushedSegmentInfos)+len(flushedSegmentInfos))
for _, us := range unflushedSegmentInfos {
@ -269,10 +272,6 @@ func (dsService *dataSyncService) initNodes(vchanInfo *datapb.VchannelInfo, tick
futures = append(futures, future)
}
//tickler will update addSegment progress to watchInfo
tickler.watch()
defer tickler.stop()
err = concurrency.AwaitAll(futures...)
if err != nil {
return err

2
internal/util/paramtable/component_param.go
View File

@ -1407,7 +1407,7 @@ func (p *dataCoordConfig) init(base *BaseTable) {
}
func (p *dataCoordConfig) initWatchTimeoutInterval() {
p.WatchTimeoutInterval = time.Duration(p.Base.ParseInt64WithDefault("dataCoord.channel.watchTimeoutInterval", 30)) * time.Second
p.WatchTimeoutInterval = time.Duration(p.Base.ParseInt64WithDefault("dataCoord.channel.watchTimeoutInterval", 120)) * time.Second
}
func (p *dataCoordConfig) initChannelBalanceSilentDuration() {