From 1e7d9ea98f03f8ce757529b42c0f2ee707cd758f Mon Sep 17 00:00:00 2001 From: Steven Danna Date: Sat, 30 Sep 2023 15:03:50 +0100 Subject: [PATCH] streamingccl: clarify that license is needed on both clusters At least one user was confused by this. Perhaps this small update will make it more clear. Fixes #111525 Release note: None --- pkg/ccl/streamingccl/streamingest/stream_ingest_manager.go | 2 +- pkg/ccl/streamingccl/streamproducer/replication_manager.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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