diff --git a/executor.go b/executor.go index 33c7c6cd8..abd557837 100644 --- a/executor.go +++ b/executor.go @@ -3031,7 +3031,7 @@ func (e *executor) executeSetValueField(ctx context.Context, index string, c *pq return ret, nil } -// executeSetValueField removes value for colID if present +// executeClearValueField removes value for colID if present func (e *executor) executeClearValueField(ctx context.Context, index string, c *pql.Call, f *Field, colID uint64, opt *execOptions) (bool, error) { span, ctx := tracing.StartSpanFromContext(ctx, "Executor.executeClearValueField") defer span.Finish() diff --git a/view.go b/view.go index 334d55d34..815e2a71e 100644 --- a/view.go +++ b/view.go @@ -408,9 +408,9 @@ func (v *view) setValue(columnID uint64, bitDepth uint, value int64) (changed bo // clearValue removes a specific value assigned to columnID func (v *view) clearValue(columnID uint64, bitDepth uint, value int64) (changed bool, err error) { shard := columnID / ShardWidth - frag, err := v.CreateFragmentIfNotExists(shard) - if err != nil { - return changed, err + frag := v.Fragment(shard) + if frag == nil { + return false, nil } return frag.clearValue(columnID, bitDepth, value) }