diff --git a/go/vt/vttablet/tabletserver/messager/message_manager.go b/go/vt/vttablet/tabletserver/messager/message_manager.go index 7a0d5825771..5719c2fd4c2 100644 --- a/go/vt/vttablet/tabletserver/messager/message_manager.go +++ b/go/vt/vttablet/tabletserver/messager/message_manager.go @@ -838,21 +838,21 @@ func BuildMessageRow(row []sqltypes.Value) (*MessageRow, error) { mr.Priority = v } if !row[1].IsNull() { - v, err := evalengine.ToInt64(row[0]) + v, err := evalengine.ToInt64(row[1]) if err != nil { return nil, err } mr.TimeNext = v } if !row[2].IsNull() { - v, err := evalengine.ToInt64(row[1]) + v, err := evalengine.ToInt64(row[2]) if err != nil { return nil, err } mr.Epoch = v } if !row[3].IsNull() { - v, err := evalengine.ToInt64(row[2]) + v, err := evalengine.ToInt64(row[3]) if err != nil { return nil, err }