From 7cb1fe8d388a2ebda038e0983eeece5dea918fdd Mon Sep 17 00:00:00 2001 From: StrikeW Date: Thu, 24 Aug 2023 14:06:27 +0800 Subject: [PATCH] fix cdc_backfill session variable --- src/common/src/session_config/mod.rs | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/common/src/session_config/mod.rs b/src/common/src/session_config/mod.rs index 507c38360c282..88bdb62b12bce 100644 --- a/src/common/src/session_config/mod.rs +++ b/src/common/src/session_config/mod.rs @@ -667,6 +667,8 @@ impl ConfigMap { Ok(self.row_security.to_string()) } else if key.eq_ignore_ascii_case(StandardConformingStrings::entry_name()) { Ok(self.standard_conforming_strings.to_string()) + } else if key.eq_ignore_ascii_case(CdcBackfill::entry_name()) { + Ok(self.cdc_backfill.to_string()) } else { Err(ErrorCode::UnrecognizedConfigurationParameter(key.to_string()).into()) } @@ -843,6 +845,11 @@ impl ConfigMap { name: StandardConformingStrings::entry_name().to_lowercase(), setting: self.standard_conforming_strings.to_string(), description: String::from("Unused in RisingWave"), + }, + VariableInfo{ + name: CdcBackfill::entry_name().to_lowercase(), + setting: self.cdc_backfill.to_string(), + description: String::from("Enable backfill for CDC table to allow lock-free and incremental snapshot"), } ] }