diff --git a/pkg/ccl/streamingccl/streamingest/stream_ingest_manager.go b/pkg/ccl/streamingccl/streamingest/stream_ingest_manager.go index 59e52be0b6a6..7413719055d6 100644 --- a/pkg/ccl/streamingccl/streamingest/stream_ingest_manager.go +++ b/pkg/ccl/streamingccl/streamingest/stream_ingest_manager.go @@ -66,7 +66,7 @@ func newStreamIngestManagerWithPrivilegesCheck( execCfg.Settings, execCfg.NodeInfo.LogicalClusterID(), "REPLICATION") if enterpriseCheckErr != nil { return nil, pgerror.Wrap(enterpriseCheckErr, - pgcode.InsufficientPrivilege, "replication requires enterprise license") + pgcode.InsufficientPrivilege, "physical replication requires an enterprise license on the secondary (and primary) cluster") } isAdmin, err := evalCtx.SessionAccessor.HasAdminRole(ctx) diff --git a/pkg/ccl/streamingccl/streamproducer/replication_manager.go b/pkg/ccl/streamingccl/streamproducer/replication_manager.go index df81b8a650f9..74600866dda1 100644 --- a/pkg/ccl/streamingccl/streamproducer/replication_manager.go +++ b/pkg/ccl/streamingccl/streamproducer/replication_manager.go @@ -92,7 +92,7 @@ func newReplicationStreamManagerWithPrivilegesCheck( execCfg.Settings, execCfg.NodeInfo.LogicalClusterID(), "REPLICATION") if enterpriseCheckErr != nil { return nil, pgerror.Wrap(enterpriseCheckErr, - pgcode.InsufficientPrivilege, "replication requires enterprise license") + pgcode.InsufficientPrivilege, "physical replication requires an enterprise license on the primary (and secondary) cluster") } return &replicationStreamManagerImpl{evalCtx: evalCtx, txn: txn}, nil diff --git a/pkg/configprofiles/profiles.go b/pkg/configprofiles/profiles.go index 4c17d60a04f1..fd0bd857cc54 100644 --- a/pkg/configprofiles/profiles.go +++ b/pkg/configprofiles/profiles.go @@ -112,7 +112,7 @@ var virtClusterInitTasks = []autoconfigpb.Task{ }, ), // Finally. - makeTask("use the application virtual cluster template by default in CREATE VIRTUAL CLSUTER", + makeTask("use the application virtual cluster template by default in CREATE VIRTUAL CLUSTER", /* nonTxnSQL */ []string{ "SET CLUSTER SETTING sql.create_virtual_cluster.default_template = 'template'", }, @@ -141,7 +141,7 @@ var virtClusterWithAppServiceInitTasks = append( ) func enableReplication(baseTasks []autoconfigpb.Task) []autoconfigpb.Task { - return append(baseTasks, + return append(baseTasks[:len(baseTasks):len(baseTasks)], makeTask("enable rangefeeds and replication", /* nonTxnSQL */ []string{ "SET CLUSTER SETTING kv.rangefeed.enabled = true", diff --git a/pkg/configprofiles/testdata/virtual-app-repl b/pkg/configprofiles/testdata/virtual-app-repl index 9fd541fb4a07..1103f07f2f79 100644 --- a/pkg/configprofiles/testdata/virtual-app-repl +++ b/pkg/configprofiles/testdata/virtual-app-repl @@ -27,8 +27,8 @@ WHERE variable IN ( ) ORDER BY variable ---- -cross_cluster_replication.enabled false -kv.rangefeed.enabled false +cross_cluster_replication.enabled true +kv.rangefeed.enabled true server.controller.default_target_cluster application spanconfig.range_coalescing.application.enabled false spanconfig.range_coalescing.system.enabled false