@@ -58,8 +58,8 @@ pub enum Error {
58
58
#[ snafu( display( "failed to build spark connect server config map for {name}" ) ) ]
59
59
BuildServerConfigMap { source : server:: Error , name : String } ,
60
60
61
- #[ snafu( display( "failed to build spark connect deployment " ) ) ]
62
- BuildServerDeployment { source : server:: Error } ,
61
+ #[ snafu( display( "failed to build spark connect stateful set " ) ) ]
62
+ BuildServerStatefulSet { source : server:: Error } ,
63
63
64
64
#[ snafu( display( "failed to update status of spark connect server {name}" ) ) ]
65
65
ApplyStatus {
@@ -70,8 +70,8 @@ pub enum Error {
70
70
#[ snafu( display( "spark connect object has no namespace" ) ) ]
71
71
ObjectHasNoNamespace ,
72
72
73
- #[ snafu( display( "failed to update the connect server deployment " ) ) ]
74
- ApplyDeployment {
73
+ #[ snafu( display( "failed to update the connect server stateful set " ) ) ]
74
+ ApplyStatefulSet {
75
75
source : stackable_operator:: cluster_resources:: Error ,
76
76
} ,
77
77
@@ -274,15 +274,15 @@ pub async fn reconcile(
274
274
// ========================================
275
275
// Server stateful set
276
276
let args = server:: command_args ( & scs. spec . args ) ;
277
- let deployment = server:: build_stateful_set (
277
+ let stateful_set = server:: build_stateful_set (
278
278
scs,
279
279
& server_config,
280
280
& resolved_product_image,
281
281
& service_account,
282
282
& server_config_map,
283
283
args,
284
284
)
285
- . context ( BuildServerDeploymentSnafu ) ?;
285
+ . context ( BuildServerStatefulSetSnafu ) ?;
286
286
287
287
// ========================================
288
288
// Server listener
@@ -298,9 +298,9 @@ pub async fn reconcile(
298
298
299
299
ss_cond_builder. add (
300
300
cluster_resources
301
- . add ( client, deployment )
301
+ . add ( client, stateful_set )
302
302
. await
303
- . context ( ApplyDeploymentSnafu ) ?,
303
+ . context ( ApplyStatefulSetSnafu ) ?,
304
304
) ;
305
305
306
306
cluster_resources
0 commit comments