Skip to content

Commit

Permalink
Merge pull request #100713 from miretskiy/disable_mux
Browse files Browse the repository at this point in the history
kvcoord, changefeedccl: Disable mux rangefeed
  • Loading branch information
miretskiy authored Apr 5, 2023
2 parents 8332ad6 + a682f7f commit c248656
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion pkg/ccl/changefeedccl/changefeedbase/settings.go
Original file line number Diff line number Diff line change
Expand Up @@ -224,7 +224,7 @@ var UseMuxRangeFeed = settings.RegisterBoolSetting(
settings.TenantWritable,
"changefeed.mux_rangefeed.enabled",
"if true, changefeed uses multiplexing rangefeed RPC",
util.ConstantWithMetamorphicTestBool("changefeed.mux_rangefeed.enabled", false),
false,
)

// EventConsumerWorkers specifies the maximum number of workers to use when
Expand Down
1 change: 0 additions & 1 deletion pkg/kv/kvclient/rangefeed/BUILD.bazel
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ go_library(
"//pkg/roachpb",
"//pkg/settings",
"//pkg/settings/cluster",
"//pkg/util",
"//pkg/util/admission/admissionpb",
"//pkg/util/ctxgroup",
"//pkg/util/hlc",
Expand Down
5 changes: 3 additions & 2 deletions pkg/kv/kvclient/rangefeed/rangefeed.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,6 @@ import (
"github.com/cockroachdb/cockroach/pkg/kv/kvpb"
"github.com/cockroachdb/cockroach/pkg/roachpb"
"github.com/cockroachdb/cockroach/pkg/settings/cluster"
"github.com/cockroachdb/cockroach/pkg/util"
"github.com/cockroachdb/cockroach/pkg/util/ctxgroup"
"github.com/cockroachdb/cockroach/pkg/util/hlc"
"github.com/cockroachdb/cockroach/pkg/util/log"
Expand Down Expand Up @@ -267,7 +266,9 @@ func (f *RangeFeed) Close() {
// will be reset.
const resetThreshold = 30 * time.Second

var useMuxRangeFeed = util.ConstantWithMetamorphicTestBool("use-mux-rangefeed", false)
// Disable mux rangefeed on 23.1 release.
// TODO(yevgeniy): Re-enable with metamorphic constant.
var useMuxRangeFeed = false

// run will run the RangeFeed until the context is canceled or if the client
// indicates that an initial scan error is non-recoverable.
Expand Down

0 comments on commit c248656

Please sign in to comment.