diff --git a/go/vt/sqlparser/parsed_query.go b/go/vt/sqlparser/parsed_query.go index a4c8b026156..b6b03a1901a 100644 --- a/go/vt/sqlparser/parsed_query.go +++ b/go/vt/sqlparser/parsed_query.go @@ -131,7 +131,7 @@ func (pq *ParsedQuery) AppendFromRow(buf *bytes2.Buffer, fields []*querypb.Field case querypb.Type_JSON: if col.length < 0 { // An SQL NULL and not an actual JSON value buf.WriteString(sqltypes.NullStr) - } else { // A JSON value (which may be an JSON null literal value) + } else { // A JSON value (which may be a JSON null literal value) buf2 := row.Values[col.offset : col.offset+col.length] vv, err := vjson.MarshalSQLValue(buf2) if err != nil { diff --git a/go/vt/vttablet/tabletmanager/vreplication/replicator_plan.go b/go/vt/vttablet/tabletmanager/vreplication/replicator_plan.go index 2fe1041a03c..39ffdef04ae 100644 --- a/go/vt/vttablet/tabletmanager/vreplication/replicator_plan.go +++ b/go/vt/vttablet/tabletmanager/vreplication/replicator_plan.go @@ -380,7 +380,7 @@ func (tp *TablePlan) applyChange(rowChange *binlogdatapb.RowChange, executor fun if field.Type == querypb.Type_JSON { if vals[i].IsNull() { // An SQL NULL and not an actual JSON value newVal = &sqltypes.NULL - } else { // A JSON value (which may be an JSON null literal value) + } else { // A JSON value (which may be a JSON null literal value) newVal, err = vjson.MarshalSQLValue(vals[i].Raw()) if err != nil { return nil, err