diff --git a/go/vt/discovery/healthcheck.go b/go/vt/discovery/healthcheck.go index d37b7419fd6..3498b144e03 100644 --- a/go/vt/discovery/healthcheck.go +++ b/go/vt/discovery/healthcheck.go @@ -855,6 +855,7 @@ func (hc *HealthCheckImpl) TabletConnection(alias *topodata.TabletAlias, target hc.mu.Unlock() if thc == nil || thc.Conn == nil { // TODO: test that throws this error + log.Warningf("NOT_FOUND: tablet: %v is either down or nonexistent", alias) return nil, vterrors.Errorf(vtrpc.Code_NOT_FOUND, "tablet: %v is either down or nonexistent", alias) } return thc.Connection(hc), nil diff --git a/go/vt/vtgate/engine/set.go b/go/vt/vtgate/engine/set.go index 9d370b6ec36..a4181d64863 100644 --- a/go/vt/vtgate/engine/set.go +++ b/go/vt/vtgate/engine/set.go @@ -540,6 +540,7 @@ func (svss *SysVarSetAware) Execute(ctx context.Context, vcursor VCursor, env *e return vterrors.NewErrorf(vtrpcpb.Code_INVALID_ARGUMENT, vterrors.WrongValueForVar, "variable 'session_track_gtids' can't be set to the value of '%s'", str) } default: + log.Warningf("NOT_FOUOND: unknown system variable '%s'", svss.Name) return vterrors.NewErrorf(vtrpcpb.Code_NOT_FOUND, vterrors.UnknownSystemVariable, "unknown system variable '%s'", svss.Name) } diff --git a/go/vt/vtgate/plan_execute.go b/go/vt/vtgate/plan_execute.go index 4e2c3bfea4c..c704a8747fe 100644 --- a/go/vt/vtgate/plan_execute.go +++ b/go/vt/vtgate/plan_execute.go @@ -201,12 +201,14 @@ func (e *Executor) handleTransactions( case sqlparser.StmtSRollback: qr, err := e.handleSavepoint(ctx, safeSession, plan.Original, "Rollback Savepoint", logStats, func(query string) (*sqltypes.Result, error) { // Error as there is no transaction, so there is no savepoint that exists. + log.Warningf("NOT_FOUND: SAVEPOINT does not exist: %s", query) return nil, vterrors.NewErrorf(vtrpcpb.Code_NOT_FOUND, vterrors.SPDoesNotExist, "SAVEPOINT does not exist: %s", query) }, vcursor.ignoreMaxMemoryRows) return qr, err case sqlparser.StmtRelease: qr, err := e.handleSavepoint(ctx, safeSession, plan.Original, "Release Savepoint", logStats, func(query string) (*sqltypes.Result, error) { // Error as there is no transaction, so there is no savepoint that exists. + log.Warningf("NOT_FOUND: SAVEPOINT does not exist: %s", query) return nil, vterrors.NewErrorf(vtrpcpb.Code_NOT_FOUND, vterrors.SPDoesNotExist, "SAVEPOINT does not exist: %s", query) }, vcursor.ignoreMaxMemoryRows) return qr, err diff --git a/go/vt/vtgate/scatter_conn.go b/go/vt/vtgate/scatter_conn.go index ede88e2d9b8..c5a0868d060 100644 --- a/go/vt/vtgate/scatter_conn.go +++ b/go/vt/vtgate/scatter_conn.go @@ -831,6 +831,7 @@ func lockInfo(target *querypb.Target, session *SafeSession, lockFuncType sqlpars info := &shardActionInfo{actionNeeded: nothing} if session.LockSession != nil { if !proto.Equal(target, session.LockSession.Target) { + log.Warningf("NOT_FOUND: target does match the existing lock session target: (%v, %v)", target, session.LockSession.Target) return nil, vterrors.Errorf(vtrpcpb.Code_NOT_FOUND, "target does match the existing lock session target: (%v, %v)", target, session.LockSession.Target) } info.reservedID = session.LockSession.ReservedId diff --git a/go/vt/vtgate/semantics/derived_table.go b/go/vt/vtgate/semantics/derived_table.go index 0425d78ed93..c1d3ced4f32 100644 --- a/go/vt/vtgate/semantics/derived_table.go +++ b/go/vt/vtgate/semantics/derived_table.go @@ -19,6 +19,7 @@ package semantics import ( "strings" + "vitess.io/vitess/go/vt/log" vtrpcpb "vitess.io/vitess/go/vt/proto/vtrpc" "vitess.io/vitess/go/vt/sqlparser" "vitess.io/vitess/go/vt/vterrors" @@ -183,6 +184,7 @@ func (dt *DerivedTable) getExprFor(s string) (sqlparser.Expr, error) { return dt.cols[i], nil } } + log.Warningf("NOT_FOUND: Unknown column '%s' in 'field list'", s) return nil, vterrors.NewErrorf(vtrpcpb.Code_NOT_FOUND, vterrors.BadFieldError, "Unknown column '%s' in 'field list'", s) } diff --git a/go/vt/vtgate/tabletgateway.go b/go/vt/vtgate/tabletgateway.go index 4c67f5672e1..337b7f05bc6 100644 --- a/go/vt/vtgate/tabletgateway.go +++ b/go/vt/vtgate/tabletgateway.go @@ -490,11 +490,15 @@ func (gw *TabletGateway) TabletsHealthyStatus() discovery.TabletsCacheStatusList } func (gw *TabletGateway) updateDefaultConnCollation(tablet *topodatapb.Tablet) { + if tablet.DefaultConnCollation == 45 { + log.Warningf("slack: unexpected collation on tablet host: %s", tablet.Hostname) + } if gw.defaultConnCollation.CompareAndSwap(0, tablet.DefaultConnCollation) { return } if gw.defaultConnCollation.Load() != tablet.DefaultConnCollation { - log.Warning("this Vitess cluster has tablets with different default connection collations") + log.Warningf("this Vitess cluster has tablets with different default connection collations: gw: %v, tablet:%v, host:%v", + gw.defaultConnCollation.Load(), tablet.DefaultConnCollation, tablet.Hostname) } } diff --git a/go/vt/vtgate/vindexes/vschema.go b/go/vt/vtgate/vindexes/vschema.go index 8559cabc447..52d48cd1bf9 100644 --- a/go/vt/vtgate/vindexes/vschema.go +++ b/go/vt/vtgate/vindexes/vschema.go @@ -29,6 +29,7 @@ import ( "vitess.io/vitess/go/mysql/collations" "vitess.io/vitess/go/sqlescape" "vitess.io/vitess/go/sqltypes" + "vitess.io/vitess/go/vt/log" querypb "vitess.io/vitess/go/vt/proto/query" topodatapb "vitess.io/vitess/go/vt/proto/topodata" vschemapb "vitess.io/vitess/go/vt/proto/vschema" @@ -493,6 +494,9 @@ func buildKeyspaceReferences(vschema *VSchema, ksvschema *KeyspaceSchema) error if vterrors.Code(err) != vtrpcpb.Code_NOT_FOUND || vterrors.ErrState(err) != vterrors.BadDb { return err } + log.Warningf("NOT_FOUND: source %q references a non-existent keyspace %q", + source, + sourceKsname) return vterrors.Errorf( vtrpcpb.Code_NOT_FOUND, "source %q references a non-existent keyspace %q", @@ -501,6 +505,10 @@ func buildKeyspaceReferences(vschema *VSchema, ksvschema *KeyspaceSchema) error ) } if sourceT == nil { + log.Warningf("NOT_FOUND: source %q references a table %q that is not present in the VSchema of keyspace %q", + source, + sourceTname, + sourceKsname) return vterrors.Errorf( vtrpcpb.Code_NOT_FOUND, "source %q references a table %q that is not present in the VSchema of keyspace %q", @@ -606,6 +614,8 @@ func buildTables(ks *vschemapb.Keyspace, vschema *VSchema, ksvschema *KeyspaceSc } t.Type = table.Type default: + log.Warningf("NOT_FOUND: unidentified table type %s", + table.Type) return vterrors.Errorf( vtrpcpb.Code_NOT_FOUND, "unidentified table type %s", @@ -828,6 +838,9 @@ func resolveAutoIncrement(source *vschemapb.SrvVSchema, vschema *VSchema, parser // Better to remove the table than to leave it partially initialized. delete(ksvschema.Tables, tname) delete(vschema.globalTables, tname) + log.Warningf("NOT_FOUND: cannot resolve sequence %s: %s", + table.AutoIncrement.Sequence, + err.Error()) ksvschema.Error = vterrors.Errorf( vtrpcpb.Code_NOT_FOUND, "cannot resolve sequence %s: %s",