Skip to content

Commit 8e4c46b

Browse files
committed
fix: adapt to optional replicas
1 parent 9653eb9 commit 8e4c46b

2 files changed

Lines changed: 4 additions & 2 deletions

File tree

rust/operator-binary/src/controller/build/resource/statefulset.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -437,7 +437,9 @@ pub(crate) fn build_metastore_rolegroup_statefulset(
437437
.build(),
438438
spec: Some(StatefulSetSpec {
439439
pod_management_policy: Some("Parallel".to_string()),
440-
replicas: Some(i32::from(rg.replicas)),
440+
// `None` (no replica count specified) leaves `.spec.replicas` unset so a
441+
// HorizontalPodAutoscaler can manage it.
442+
replicas: rg.replicas.map(i32::from),
441443
selector: LabelSelector {
442444
match_labels: Some(cluster.role_group_selector(role_group_name).into()),
443445
..LabelSelector::default()

rust/operator-binary/src/controller/validate.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -279,7 +279,7 @@ fn validate_role_group_config(
279279
)?;
280280

281281
Ok(HiveRoleGroupConfig {
282-
replicas: merged.replicas.unwrap_or(1),
282+
replicas: merged.replicas,
283283
config: ValidatedMetaStoreConfig::from_merged(merged.config.config, logging),
284284
config_overrides: merged.config.config_overrides,
285285
env_overrides,

0 commit comments

Comments
 (0)