diff --git a/pkg/ingester/ingester.go b/pkg/ingester/ingester.go index d1d77b42a57e29a4606b5a78837bcd021ba5422a..cc78087dd5d21da9b49039c38866162bc63ac9a0 100644 --- a/pkg/ingester/ingester.go +++ b/pkg/ingester/ingester.go @@ -173,7 +173,7 @@ func (i *Ingester) Push(ctx context.Context, req *logproto.PushRequest) (*logpro func (i *Ingester) getOrCreateInstance(instanceID string) *instance { inst, ok := i.getInstanceByID(instanceID) - if ok || i.readonly { + if ok { return inst } diff --git a/pkg/ingester/transfer.go b/pkg/ingester/transfer.go index c329dab083b48139e101ae2ef8121461ea086b73..a249ef2a0b275190d69aa6a98698e3daeeb766ac 100644 --- a/pkg/ingester/transfer.go +++ b/pkg/ingester/transfer.go @@ -29,7 +29,7 @@ var ( }) ) -// TransferChunks receieves all chunks from another ingester. The Ingester +// TransferChunks receives all chunks from another ingester. The Ingester // must be in PENDING state or else the call will fail. func (i *Ingester) TransferChunks(stream logproto.Ingester_TransferChunksServer) error { // Entry JOINING state (only valid from PENDING)