diff --git a/go/storage/schema/schema.go b/go/storage/schema/schema.go index 9c560e5..5876c8e 100644 --- a/go/storage/schema/schema.go +++ b/go/storage/schema/schema.go @@ -125,7 +125,7 @@ func (s *Schema) BuildDeleteSchema() error { } versionField, ok := s.schema.FieldsByName(s.options.VersionColumn) if !ok { - return ErrPrimaryColumnNotFound + return ErrVersionColumnNotFound } fields := make([]arrow.Field, 0, 2) fields = append(fields, pkColumn[0])