diff --git a/pkg/sql/conn_executor_ddl.go b/pkg/sql/conn_executor_ddl.go index f7f32ff673b2..392c8fd9ff02 100644 --- a/pkg/sql/conn_executor_ddl.go +++ b/pkg/sql/conn_executor_ddl.go @@ -82,7 +82,13 @@ func (ex *connExecutor) maybeAdjustTxnForDDL(ctx context.Context, stmt Statement return err } ex.extraTxnState.upgradedToSerializable = true - p.BufferClientNotice(ctx, pgnotice.Newf("setting transaction isolation level to SERIALIZABLE due to schema change")) + if err := p.SendClientNotice( + ctx, + pgnotice.Newf("setting transaction isolation level to SERIALIZABLE due to schema change"), + false, /* immediateFlush */ + ); err != nil { + return err + } } else { return txnSchemaChangeErr }