scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-08-28 10:54:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

adds more detail to CSV ingest error message

Browse source
This commit is contained in:
kcrodgers24 2021-10-07 13:56:06 -07:00
parent 0d548094eb
commit 1f257aab9c
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
client/batch.go
View file

@ -1277,7 +1277,7 @@ func (b *Batch) importValueData() error {
start := time.Now()
err := b.client.DoImportValues(b.index.Name(), shard, path, data)
b.log.Debugf("imp-vals %s,shard:%d,data:%d %v", field, shard, len(data), time.Since(start))
return errors.Wrapf(err, "importing values for %s", field)
return errors.Wrapf(err, "importing values for field = %s", field)
})
startIdx = i
curShard = recordID / shardWidth
@ -1350,7 +1350,7 @@ func (b *Batch) importMutexData() error {
start := time.Now()
err := b.client.DoImport(b.index.Name(), shard, path, data)
b.log.Debugf("imp-mux %s,shard:%d,data:%d %v", field.Name(), shard, len(data), time.Since(start))
return errors.Wrapf(err, "importing values for %s", field)
return errors.Wrapf(err, "importing values for field = %s", field)
})
startIdx = i
curShard = recordID / shardWidth

4
field.go
View file

@ -1683,9 +1683,9 @@ func (f *Field) importValue(qcx *Qcx, columnIDs []uint64, values []int64, shard
for i := range columnIDs {
columnID, value := columnIDs[i], values[i]
if value > bsig.Max {
return fmt.Errorf("%v, columnID=%v, value=%v", ErrBSIGroupValueTooHigh, columnID, value)
return fmt.Errorf("%v, value=%v, columnID=%v", ErrBSIGroupValueTooHigh, value, columnID)
} else if value < bsig.Min {
return fmt.Errorf("%v, columnID=%v, value=%v", ErrBSIGroupValueTooLow, columnID, value)
return fmt.Errorf("%v, value=%v, columnID=%v", ErrBSIGroupValueTooLow, value, columnID)
}
if value > max {
max = value