Skip to content

Commit

Permalink
[#25413] CDC: Enable dynamic table addition by default in logical rep…
Browse files Browse the repository at this point in the history
…lication

Summary:
This revision converts the preview flag `cdcsdk_enable_dynamic_table_support` to a runtime
flag with default value `true`. With this revision dynamic table addition will be enabled by default
for logical replication.
Jira: DB-14644

Test Plan: Existing tests

Reviewers: skumar, siddharth.shah

Reviewed By: siddharth.shah

Subscribers: ycdcxcluster

Tags: #jenkins-ready

Differential Revision: https://phorge.dev.yugabyte.com/D40857
  • Loading branch information
Sumukh-Phalgaonkar committed Dec 23, 2024
1 parent aa450d5 commit 6c8808a
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -71,20 +71,15 @@ protected int getInitialNumTServers() {
protected Map<String, String> getTServerFlags() {
Map<String, String> flagMap = super.getTServerFlags();
if (isTestRunningWithConnectionManager()) {
String preview_flags = "enable_ysql_conn_mgr," +
"cdcsdk_enable_dynamic_table_support";
String preview_flags = "enable_ysql_conn_mgr";
flagMap.put("allowed_preview_flags_csv",preview_flags);
flagMap.put("ysql_conn_mgr_stats_interval", "1");
} else {
flagMap.put("allowed_preview_flags_csv",
"cdcsdk_enable_dynamic_table_support");
}
flagMap.put(
"vmodule", "cdc_service=4,cdcsdk_producer=4,ybc_pggate=4,cdcsdk_virtual_wal=4,client=4");
flagMap.put("ysql_log_min_messages", "DEBUG2");
flagMap.put(
"cdcsdk_publication_list_refresh_interval_secs","" + kPublicationRefreshIntervalSec);
flagMap.put("cdcsdk_enable_dynamic_table_support", "true");
flagMap.put("cdc_send_null_before_image_if_not_exists", "true");
return flagMap;
}
Expand Down
4 changes: 2 additions & 2 deletions src/yb/cdc/cdcsdk_virtual_wal.cc
Original file line number Diff line number Diff line change
Expand Up @@ -68,8 +68,8 @@ DEFINE_test_flag(
"Interval in micro seconds at which the table list in the publication will be refreshed. This "
"will be used only when cdcsdk_use_microseconds_refresh_interval is set to true");

DEFINE_RUNTIME_PREVIEW_bool(
cdcsdk_enable_dynamic_table_support, false,
DEFINE_RUNTIME_bool(
cdcsdk_enable_dynamic_table_support, true,
"This flag can be used to switch the dynamic addition of tables ON or OFF.");

namespace yb {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,6 @@ class CDCSDKConsumptionConsistentChangesTest : public CDCSDKYsqlTest {
CDCSDKYsqlTest::SetUp();
ANNOTATE_UNPROTECTED_WRITE(FLAGS_yb_enable_cdc_consistent_snapshot_streams) = true;
ANNOTATE_UNPROTECTED_WRITE(FLAGS_ysql_yb_enable_replication_slot_consumption) = true;
ANNOTATE_UNPROTECTED_WRITE(FLAGS_cdcsdk_enable_dynamic_table_support) = true;
ANNOTATE_UNPROTECTED_WRITE(FLAGS_enable_cdcsdk_setting_get_changes_response_byte_limit) = true;
}

Expand Down

0 comments on commit 6c8808a

Please sign in to comment.