fix wrong error variable used (#4206)

This commit is contained in:
jennifersp
2022-08-30 09:51:38 -07:00
committed by GitHub
parent 8e7c9bf405
commit eba3d641c6
2 changed files with 9 additions and 1 deletions
@@ -74,7 +74,7 @@ func NewParquetReader(vrw types.ValueReadWriter, fr source.ParquetFile, sche sch
for _, col := range columns {
colData, _, _, cErr := pr.ReadColumnByPath(common.ReformPathStr(fmt.Sprintf("parquet_go_root.%s", col.Name)), num)
if cErr != nil {
return nil, err
return nil, fmt.Errorf("cannot read column: %s", cErr.Error())
}
data[col.Name] = colData
colName = append(colName, col.Name)
@@ -445,6 +445,14 @@ DELIM
[[ "$output" = "" ]] || false
}
@test "import-update-tables: bad parquet file import errors" {
dolt sql -q "CREATE TABLE test_table (pk int primary key, col1 text, col2 int);"
echo "This is a bad parquet file" > bad.parquet
run dolt table import -u test_table bad.parquet
[ "$status" -eq 1 ]
[[ "$output" =~ "When attempting to move data from parquet file:bad.parquet to test_table, could not open a reader." ]] || false
}
@test "import-update-tables: Subsequent updates with --continue correctly work" {
dolt sql -q "create table t (pk int primary key, val varchar(1))"
cat <<DELIM > file1.csv