support custom

risingwavelabs · Apr 1, 2024 · 2152109 · 2152109
1 parent 57da886
commit 2152109
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/ctl/src/cmd_impl/meta/migration.rs b/src/ctl/src/cmd_impl/meta/migration.rs
@@ -395,7 +395,7 @@ pub async fn migrate(from: EtcdBackend, target: String, force_clean: bool) -> an
         let streaming_parallelism = match &table_fragment.assigned_parallelism {
             TableParallelism::Adaptive => StreamingParallelism::Adaptive,
             TableParallelism::Fixed(n) => StreamingParallelism::Fixed(*n),
-            TableParallelism::Custom => todo!("custom parallelism"),
+            TableParallelism::Custom => StreamingParallelism::Custom,
         };
         let status = match table_fragment.state() {
             State::Unspecified => unreachable!(),