Skip to content

Commit

Permalink
Merge #105270
Browse files Browse the repository at this point in the history
105270: rangefeed/changefeed: Enable mux rangefeeds by default. r=aliher1911 a=aliher1911

Make mux range feeds default implementation for rangefeeds. This is done in preparation for mux range feeds becoming default from release 23.2.

Release note (performance improvement): mux range feeds reuse connection and workers across multiple range feeds. This mode is now enabled by default.

Jira-Issue: [CRDB-28547](https://cockroachlabs.atlassian.net/browse/CRDB-28547)

Co-authored-by: Oleg Afanasyev <[email protected]>
  • Loading branch information
craig[bot] and aliher1911 committed Jun 22, 2023
2 parents 71228e5 + de65c54 commit ea53fcc
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 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 @@ -233,7 +233,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),
util.ConstantWithMetamorphicTestBool("changefeed.mux_rangefeed.enabled", true),
)

// EventConsumerWorkers specifies the maximum number of workers to use when
Expand Down
2 changes: 1 addition & 1 deletion pkg/kv/kvclient/rangefeed/rangefeed.go
Original file line number Diff line number Diff line change
Expand Up @@ -267,7 +267,7 @@ func (f *RangeFeed) Close() {
// will be reset.
const resetThreshold = 30 * time.Second

var useMuxRangeFeed = util.ConstantWithMetamorphicTestBool("use-mux-rangefeed", false)
var useMuxRangeFeed = util.ConstantWithMetamorphicTestBool("use-mux-rangefeed", true)

// 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 ea53fcc

Please sign in to comment.