diff --git a/pkg/ccl/changefeedccl/changefeed_dist.go b/pkg/ccl/changefeedccl/changefeed_dist.go index 8ec05e054c65..b87f34b97741 100644 --- a/pkg/ccl/changefeedccl/changefeed_dist.go +++ b/pkg/ccl/changefeedccl/changefeed_dist.go @@ -313,7 +313,9 @@ func startDistChangefeed( finishedSetupFn = func(flowinfra.Flow) { resultsCh <- tree.Datums(nil) } } - jobsprofiler.StorePlanDiagram(ctx, execCfg.DistSQLSrv.Stopper, p, execCfg.InternalDB, jobID) + if log.V(1) { + jobsprofiler.StorePlanDiagram(ctx, execCfg.DistSQLSrv.Stopper, p, execCfg.InternalDB, jobID) + } // Make sure to use special changefeed monitor going forward as the // parent monitor for the DistSQL infrastructure. This is needed to diff --git a/pkg/jobs/jobsprofiler/profiler_test.go b/pkg/jobs/jobsprofiler/profiler_test.go index 413a485ccbc4..bbacd6c5045e 100644 --- a/pkg/jobs/jobsprofiler/profiler_test.go +++ b/pkg/jobs/jobsprofiler/profiler_test.go @@ -77,11 +77,14 @@ func TestProfilerStorePlanDiagram(t *testing.T) { sql: "RESTORE TABLE foo FROM LATEST IN 'userfile:///foo' WITH into_db='test'", typ: jobspb.TypeRestore, }, - { - name: "changefeed", - sql: "CREATE CHANGEFEED FOR foo INTO 'null://sink'", - typ: jobspb.TypeChangefeed, - }, + /* + TODO(dt): re-enable this once #126083 is fixed. + { + name: "changefeed", + sql: "CREATE CHANGEFEED FOR foo INTO 'null://sink'", + typ: jobspb.TypeChangefeed, + }, + */ } { t.Run(tc.name, func(t *testing.T) { _, err := sqlDB.Exec(tc.sql)