diff --git a/internal/datacoord/policy.go b/internal/datacoord/policy.go index e4d8a47b9f..d7ebd5cbcc 100644 --- a/internal/datacoord/policy.go +++ b/internal/datacoord/policy.go @@ -22,11 +22,12 @@ import ( "time" "github.com/golang/protobuf/proto" + "go.uber.org/zap" + "stathat.com/c/consistent" + "github.com/milvus-io/milvus/internal/kv" "github.com/milvus-io/milvus/internal/log" "github.com/milvus-io/milvus/internal/proto/datapb" - "go.uber.org/zap" - "stathat.com/c/consistent" ) // RegisterPolicy decides the channels mapping after registering the nodeID