diff --git a/src/meta/service/src/scale_service.rs b/src/meta/service/src/scale_service.rs index f36a3c3ec0f0e..273fdbca9bc07 100644 --- a/src/meta/service/src/scale_service.rs +++ b/src/meta/service/src/scale_service.rs @@ -210,6 +210,7 @@ impl ScaleService for ScaleServiceImpl { .collect(), RescheduleOptions { resolve_no_shuffle_upstream, + skip_create_new_actors: false, }, Some(table_parallelisms), ) diff --git a/src/meta/src/barrier/recovery.rs b/src/meta/src/barrier/recovery.rs index 2b26fc7886c4a..32da2371d5277 100644 --- a/src/meta/src/barrier/recovery.rs +++ b/src/meta/src/barrier/recovery.rs @@ -697,6 +697,7 @@ impl GlobalBarrierManagerContext { plan, RescheduleOptions { resolve_no_shuffle_upstream: true, + skip_create_new_actors: true, }, Some(&mut compared_table_parallelisms), ) @@ -828,6 +829,7 @@ impl GlobalBarrierManagerContext { plan, RescheduleOptions { resolve_no_shuffle_upstream: true, + skip_create_new_actors: true, }, Some(&mut compared_table_parallelisms), ) diff --git a/src/meta/src/stream/scale.rs b/src/meta/src/stream/scale.rs index d0c839003930b..b113c2b6cb92e 100644 --- a/src/meta/src/stream/scale.rs +++ b/src/meta/src/stream/scale.rs @@ -2818,6 +2818,7 @@ impl GlobalStreamManager { reschedules, RescheduleOptions { resolve_no_shuffle_upstream: false, + skip_create_new_actors: false, }, None, ) diff --git a/src/meta/src/stream/stream_manager.rs b/src/meta/src/stream/stream_manager.rs index a949780e06ed1..0385fd57a29f9 100644 --- a/src/meta/src/stream/stream_manager.rs +++ b/src/meta/src/stream/stream_manager.rs @@ -727,6 +727,7 @@ impl GlobalStreamManager { reschedules, RescheduleOptions { resolve_no_shuffle_upstream: false, + skip_create_new_actors: false, }, Some(table_parallelism_assignment), )