Skip to content
Snippets Groups Projects
Commit 4c3486c7 authored by neza2017's avatar neza2017 Committed by yefu.chen
Browse files

Fix timestamp allocator


Signed-off-by: default avatarneza2017 <yefu.chen@zilliz.com>
parent a391d4fb
No related branches found
No related tags found
No related merge requests found
......@@ -2,16 +2,15 @@ package allocator
import (
"context"
"github.com/zilliztech/milvus-distributed/internal/util/retry"
"google.golang.org/grpc"
"log"
"time"
"github.com/zilliztech/milvus-distributed/internal/errors"
"github.com/zilliztech/milvus-distributed/internal/proto/commonpb"
"github.com/zilliztech/milvus-distributed/internal/proto/masterpb"
"github.com/zilliztech/milvus-distributed/internal/util/retry"
"github.com/zilliztech/milvus-distributed/internal/util/typeutil"
"google.golang.org/grpc"
)
type Timestamp = typeutil.Timestamp
......@@ -148,7 +147,7 @@ func (ta *TimestampAllocator) Alloc(count uint32) ([]Timestamp, error) {
req.Wait()
if !req.IsValid() {
return nil, nil
return nil, errors.Errorf("alloc time stamp request failed")
}
start, count := req.timestamp, req.count
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment