Minor fixes

capillariesio · Apr 13, 2024 · e173d3e · e173d3e
1 parent 2d92ed3
commit e173d3e
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/test/code/parquet/capiparquet.go b/test/code/parquet/capiparquet.go
@@ -278,7 +278,11 @@ func cat(path string) error {
 				if err != nil {
 					return fmt.Errorf("cannot read string row %d, column %s: %s", rowIdx, fieldName, err.Error())
 				}
-				sb.WriteString(typedVal)
+				if strings.Contains(typedVal, `,`) {
+					sb.WriteString(fmt.Sprintf(`"%s"`, typedVal))
+				} else {
+					sb.WriteString(typedVal)
+				}
 
 			case sc.FieldTypeInt:
 				typedVal, err := storage.ParquetReadInt(volatile, se)

diff --git a/test/data/cfg/fannie_mae_quicktest/script.json b/test/data/cfg/fannie_mae_quicktest/script.json
@@ -878,7 +878,7 @@
 						"type": "decimal2"
 					},
 					{
-						"parquet": { "column_name": "total_original_`upb_paid_off_ratio" },
+						"parquet": { "column_name": "total_original_upb_paid_off_ratio" },
 						"name": "total_original_upb_paid_off_ratio",
 						"expression": "math.Round(float(r.total_paid_off_amount)/float(r.total_original_upb)*100000)/100000",
 						"type": "float"