Skip to content

Commit 3b79c8d

Browse files
committed
fix: use optional replicas
1 parent 0e1ae0c commit 3b79c8d

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -325,7 +325,7 @@ pub fn build_rolegroup_statefulset(
325325

326326
let statefulset_spec = StatefulSetSpec {
327327
pod_management_policy: Some("Parallel".to_string()),
328-
replicas: Some(i32::from(validated_rg_config.replicas)),
328+
replicas: validated_rg_config.replicas.map(i32::from),
329329
selector: LabelSelector {
330330
match_labels: Some(statefulset_match_labels.into()),
331331
..LabelSelector::default()

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -294,7 +294,7 @@ where
294294
let logging = validate_logging(config.logging(), vector_aggregator_config_map_name)?;
295295

296296
let validated = HbaseRoleGroupConfig {
297-
replicas: validated.replicas.unwrap_or(1),
297+
replicas: validated.replicas,
298298
config: ValidatedHbaseConfig { config, logging },
299299
config_overrides,
300300
env_overrides: env_overrides_set,

0 commit comments

Comments
 (0)