diff --git a/src/frontend/src/handler/create_table.rs b/src/frontend/src/handler/create_table.rs index 65a6fa553b7a2..d6eed9f9e4053 100644 --- a/src/frontend/src/handler/create_table.rs +++ b/src/frontend/src/handler/create_table.rs @@ -1452,6 +1452,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." }, } }; }