diff --git a/src/frontend/src/handler/create_table.rs b/src/frontend/src/handler/create_table.rs index e68d34e85928d..f26cc53a4914f 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 0d10d76869b0f..a0040a2c00d2b 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." }, } }; }