Merge cockroachdb#137359 cockroachdb#137432

137359: changefeedccl/kvfeed: add log for table that encountered schema change r=rharding6373 a=andyyang890

This patch adds a log documenting the table(s) that encountered schema
changes and caused the kv feed to restart/exit, which will be useful
for debugging.

Fixes cockroachdb#136624
Closes cockroachdb#134963

Release note: None

137432: docgen: remove unused BEGIN diagram r=yuzefovich a=taroface

 cockroachdb#137135 added `begin_stmt` to the .bzl files for SQL diagram generation. However, this diagram is no longer used, and doesn't seem to be generated by `docgen` upon local testing. Removing `begin_stmt` and `begin_stmt.bnf` worked in cockroachdb#137111, so this PR applies the same update to `master` and backports to 24.1-3. (cc `@rickystewart)`

Epic: none
Release note: None

Co-authored-by: Andy Yang <yang@cockroachlabs.com>
Co-authored-by: Ryan Kuo <ryank@cockroachlabs.com>

Author: 3 people

docs/generated/sql/bnf/BUILD.bazel

@@ -73,7 +73,6 @@ FILES = [
     "backup",
     "backup_options",
     "begin_transaction",
-    "begin_stmt",
     "call",
     "cancel_all_jobs",
     "cancel_job",

docs/generated/sql/bnf/begin_stmt.bnf

@@ -36,6 +36,7 @@ go_library(
         "//pkg/util/span",
         "//pkg/util/timeutil",
         "@com_github_cockroachdb_errors//:errors",
+        "@com_github_cockroachdb_redact//:redact",
     ],
 )
 

pkg/ccl/changefeedccl/kvfeed/BUILD.bazel

@@ -31,6 +31,7 @@ import (
 	"github.com/cockroachdb/cockroach/pkg/util/span"
 	"github.com/cockroachdb/cockroach/pkg/util/timeutil"
 	"github.com/cockroachdb/errors"
+	"github.com/cockroachdb/redact"
 )
 
 // MonitoringConfig is a set of callbacks which the kvfeed calls to provide
@@ -392,8 +393,15 @@ func (f *kvFeed) run(ctx context.Context) (err error) {
 			return err
 		}
 		if log.V(2) {
-			log.Infof(ctx, "kv feed encountered table events: %#v", events)
+			log.Infof(ctx, "kv feed encountered table events at or before %s: %#v", schemaChangeTS, events)
 		}
+		var tables []redact.RedactableString
+		for _, event := range events {
+			tables = append(tables, redact.Sprintf("table %q (id %d, version %d -> %d)",
+				redact.Safe(event.Before.GetName()), event.Before.GetID(), event.Before.GetVersion(), event.After.GetVersion()))
+		}
+		log.Infof(ctx, "kv feed encountered schema change(s) at or before %s: %s",
+			schemaChangeTS, redact.Join(", ", tables))
 
 		// Detect whether the event corresponds to a primary index change. Also
 		// detect whether the change corresponds to any change in the set of visible

pkg/ccl/changefeedccl/kvfeed/kv_feed.go

@@ -72,7 +72,6 @@ BNF_SRCS = [
     "//docs/generated/sql/bnf:analyze_stmt.bnf",
     "//docs/generated/sql/bnf:backup.bnf",
     "//docs/generated/sql/bnf:backup_options.bnf",
-    "//docs/generated/sql/bnf:begin_stmt.bnf",
     "//docs/generated/sql/bnf:begin_transaction.bnf",
     "//docs/generated/sql/bnf:call.bnf",
     "//docs/generated/sql/bnf:cancel_all_jobs.bnf",

pkg/gen/bnf.bzl

@@ -72,7 +72,6 @@ DIAGRAMS_SRCS = [
     "//docs/generated/sql/bnf:analyze.html",
     "//docs/generated/sql/bnf:backup.html",
     "//docs/generated/sql/bnf:backup_options.html",
-    "//docs/generated/sql/bnf:begin.html",
     "//docs/generated/sql/bnf:begin_transaction.html",
     "//docs/generated/sql/bnf:call.html",
     "//docs/generated/sql/bnf:cancel.html",

pkg/gen/diagrams.bzl

@@ -85,7 +85,6 @@ DOCS_SRCS = [
     "//docs/generated/sql/bnf:analyze_stmt.bnf",
     "//docs/generated/sql/bnf:backup.bnf",
     "//docs/generated/sql/bnf:backup_options.bnf",
-    "//docs/generated/sql/bnf:begin_stmt.bnf",
     "//docs/generated/sql/bnf:begin_transaction.bnf",
     "//docs/generated/sql/bnf:call.bnf",
     "//docs/generated/sql/bnf:cancel_all_jobs.bnf",