mirror of https://github.com/milvus-io/milvus.git
parent
b3d33a78f5
commit
851794598e
|
@ -417,7 +417,7 @@ func (node *QueryNode) ReleasePartitions(ctx context.Context, in *queryPb.Releas
|
||||||
log.Error(err.Error())
|
log.Error(err.Error())
|
||||||
return status, nil
|
return status, nil
|
||||||
}
|
}
|
||||||
log.Debug("releasePartitionsTask Enqueue done", zap.Any("collectionID", in.CollectionID))
|
log.Debug("releasePartitionsTask Enqueue done", zap.Int64("collectionID", in.CollectionID), zap.Int64s("partitionIDs", in.PartitionIDs))
|
||||||
|
|
||||||
func() {
|
func() {
|
||||||
err = dct.WaitToFinish()
|
err = dct.WaitToFinish()
|
||||||
|
@ -425,7 +425,7 @@ func (node *QueryNode) ReleasePartitions(ctx context.Context, in *queryPb.Releas
|
||||||
log.Error(err.Error())
|
log.Error(err.Error())
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
log.Debug("releasePartitionsTask WaitToFinish done", zap.Any("collectionID", in.CollectionID))
|
log.Debug("releasePartitionsTask WaitToFinish done", zap.Int64("collectionID", in.CollectionID), zap.Int64s("partitionIDs", in.PartitionIDs))
|
||||||
}()
|
}()
|
||||||
|
|
||||||
status := &commonpb.Status{
|
status := &commonpb.Status{
|
||||||
|
|
Loading…
Reference in New Issue