mirror of https://github.com/milvus-io/milvus.git
Fix miss to handle the error of allocating ts (#27264)
Signed-off-by: yah01 <yah2er0ne@outlook.com>pull/27275/head
parent
916528f51a
commit
773080df24
|
@ -99,6 +99,9 @@ func (s *Server) Flush(ctx context.Context, req *datapb.FlushRequest) (*datapb.F
|
|||
ts, err := s.allocator.allocTimestamp(ctx)
|
||||
if err != nil {
|
||||
log.Warn("unable to alloc timestamp", zap.Error(err))
|
||||
return &datapb.FlushResponse{
|
||||
Status: merr.Status(err),
|
||||
}, nil
|
||||
}
|
||||
timeOfSeal, _ := tsoutil.ParseTS(ts)
|
||||
|
||||
|
|
Loading…
Reference in New Issue