From fb006d56adfcd82ddf2d77a37008a0d57dc535fe Mon Sep 17 00:00:00 2001 From: Dylan Chen Date: Mon, 27 Jan 2025 14:12:04 +0800 Subject: [PATCH] make iceberg engine a paid feature --- src/frontend/src/handler/create_table.rs | 3 +++ src/license/src/feature.rs | 1 + 2 files changed, 4 insertions(+) diff --git a/src/frontend/src/handler/create_table.rs b/src/frontend/src/handler/create_table.rs index a8590d3480947..10ee3a31a9852 100644 --- a/src/frontend/src/handler/create_table.rs +++ b/src/frontend/src/handler/create_table.rs @@ -1448,6 +1448,9 @@ pub async fn create_iceberg_engine_table( constraints: Vec, table_name: ObjectName, ) -> Result<()> { + risingwave_common::license::Feature::IcebergEngine + .check_available() + .map_err(|e| anyhow::anyhow!(e))?; // 1. fetch iceberg engine options from the meta node. // 2. create a hummock table // 3. create an iceberg sink diff --git a/src/license/src/feature.rs b/src/license/src/feature.rs index 5243001634e22..61a803149cccb 100644 --- a/src/license/src/feature.rs +++ b/src/license/src/feature.rs @@ -57,6 +57,7 @@ macro_rules! for_all_features { { SqlServerCdcSource, Paid, "CDC source connector for Sql Server." }, { CdcAutoSchemaChange, Paid, "Auto replicate upstream DDL to CDC Table." }, { IcebergSinkWithGlue, Paid, "Delivering data to Iceberg with Glue catalog." }, + { IcebergEngine, Paid, "Creating table with an iceberg engine." }, } }; }