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: panic when schema change (#42727)

Browse Source 
issue: #42723

Signed-off-by: chyezh <chyezh@outlook.com>
This commit is contained in:
Zhen Ye 2025-06-13 17:43:07 +08:00 committed by GitHub
parent d0eabf0807
commit 4f5409e1fe
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/mq/msgdispatcher/dispatcher.go
View File

@ -145,6 +145,7 @@ func NewDispatcher(
pchannel: pchannel,
targets: typeutil.NewConcurrentMap[string, *target](),
stream: stream,
includeSkipWhenSplit: includeSkipWhenSplit,
}
metrics.NumConsumers.WithLabelValues(paramtable.GetRole(), fmt.Sprint(paramtable.GetNodeID())).Inc()
@ -271,7 +272,6 @@ func (d *Dispatcher) work() {
log.Debug("skip msg info",
zap.String("vchannel", vchannel),
zap.String("msgType", msg.Type().String()),
zap.Int64("msgID", msg.ID()),
zap.Uint64("msgBeginTs", msg.BeginTs()),
zap.Uint64("msgEndTs", msg.EndTs()),
zap.Uint64("packBeginTs", p.BeginTs),

4
pkg/streaming/util/message/adaptor/ts_msg_newer.go
View File

@ -127,6 +127,10 @@ type SchemaChangeMessageBody struct {
SchemaChangeMessage message.ImmutableSchemaChangeMessageV2
}
func (s *SchemaChangeMessageBody) ID() msgstream.UniqueID {
return 0
}
func NewSchemaChangeMessageBody(msg message.ImmutableMessage) (msgstream.TsMsg, error) {
schChgMsg, err := message.AsImmutableCollectionSchemaChangeV2(msg)
if err != nil {