@@ -1064,11 +1064,12 @@ async fn build_node_rolegroup_statefulset(
1064
1064
) ;
1065
1065
1066
1066
let nifi_container_name = Container :: Nifi . to_string ( ) ;
1067
- let mut container_builder = ContainerBuilder :: new ( & nifi_container_name) . with_context ( |_| {
1068
- IllegalContainerNameSnafu {
1069
- container_name : nifi_container_name,
1070
- }
1071
- } ) ?;
1067
+ let mut container_nifi_builder =
1068
+ ContainerBuilder :: new ( & nifi_container_name) . with_context ( |_| {
1069
+ IllegalContainerNameSnafu {
1070
+ container_name : nifi_container_name,
1071
+ }
1072
+ } ) ?;
1072
1073
1073
1074
let nifi_args = vec ! [ formatdoc! { "
1074
1075
{COMMON_BASH_TRAP_FUNCTIONS}
@@ -1084,7 +1085,7 @@ async fn build_node_rolegroup_statefulset(
1084
1085
create_vector_shutdown_file_command =
1085
1086
create_vector_shutdown_file_command( STACKABLE_LOG_DIR ) ,
1086
1087
} ] ;
1087
- let container_nifi = container_builder
1088
+ let container_nifi = container_nifi_builder
1088
1089
. image_from_product_image ( resolved_product_image)
1089
1090
. command ( vec ! [
1090
1091
"/bin/bash" . to_string( ) ,
@@ -1226,6 +1227,8 @@ async fn build_node_rolegroup_statefulset(
1226
1227
1227
1228
// We want to add nifi container first for easier defaulting into this container
1228
1229
pod_builder. add_container ( container_nifi. build ( ) ) ;
1230
+ // After calling `build()` the ContainerBuilder shouldn't be used anymore, so we drop it
1231
+ drop ( container_nifi_builder) ;
1229
1232
1230
1233
for container in git_sync_resources. git_sync_containers . iter ( ) . cloned ( ) {
1231
1234
pod_builder. add_container ( container) ;
@@ -1294,10 +1297,7 @@ async fn build_node_rolegroup_statefulset(
1294
1297
}
1295
1298
1296
1299
authentication_config
1297
- . add_volumes_and_mounts (
1298
- & mut pod_builder,
1299
- vec ! [ & mut container_prepare, container_nifi] ,
1300
- )
1300
+ . add_volumes_and_mounts ( & mut pod_builder, vec ! [ & mut container_prepare] )
1301
1301
. context ( AddAuthVolumesSnafu ) ?;
1302
1302
1303
1303
let metadata = ObjectMetaBuilder :: new ( )
0 commit comments