Skip to content

Commit 07a134e

Browse files
Merge pull request #34104 from bobbyiliev/orechestratord-envd-http-probes-revert
orchestratord: revert to TCP probes for environmentd health checks
2 parents 261bf5e + 28a9576 commit 07a134e

File tree

1 file changed

+10
-27
lines changed

1 file changed

+10
-27
lines changed

src/orchestratord/src/controller/materialize/environmentd.rs

Lines changed: 10 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,8 @@ use k8s_openapi::{
1919
apps::v1::{StatefulSet, StatefulSetSpec, StatefulSetUpdateStrategy},
2020
core::v1::{
2121
Capabilities, ConfigMap, ConfigMapVolumeSource, Container, ContainerPort, EnvVar,
22-
EnvVarSource, HTTPGetAction, KeyToPath, PodSecurityContext, PodSpec, PodTemplateSpec,
23-
Probe, SeccompProfile, Secret, SecretKeySelector, SecretVolumeSource, SecurityContext,
22+
EnvVarSource, KeyToPath, PodSecurityContext, PodSpec, PodTemplateSpec, Probe,
23+
SeccompProfile, Secret, SecretKeySelector, SecretVolumeSource, SecurityContext,
2424
Service, ServiceAccount, ServicePort, ServiceSpec, TCPSocketAction, Toleration, Volume,
2525
VolumeMount,
2626
},
@@ -1313,31 +1313,14 @@ fn create_environmentd_statefulset_object(
13131313
args.extend(extra_args.iter().cloned());
13141314
}
13151315

1316-
let probe = if mz.meets_minimum_version(&V147_DEV0) {
1317-
Probe {
1318-
initial_delay_seconds: Some(1),
1319-
failure_threshold: Some(12),
1320-
http_get: Some(HTTPGetAction {
1321-
path: Some("/api/readyz".to_string()),
1322-
port: IntOrString::Int(config.environmentd_internal_http_port.into()),
1323-
host: None,
1324-
scheme: None,
1325-
http_headers: None,
1326-
}),
1327-
..Default::default()
1328-
}
1329-
} else {
1330-
// Older versions, despite having the /api/readyz endpoint,
1331-
// would sometimes never return an HTTP 200 response.
1332-
Probe {
1333-
initial_delay_seconds: Some(1),
1334-
failure_threshold: Some(12),
1335-
tcp_socket: Some(TCPSocketAction {
1336-
host: None,
1337-
port: IntOrString::Int(config.environmentd_sql_port.into()),
1338-
}),
1339-
..Default::default()
1340-
}
1316+
let probe = Probe {
1317+
initial_delay_seconds: Some(1),
1318+
failure_threshold: Some(12),
1319+
tcp_socket: Some(TCPSocketAction {
1320+
host: None,
1321+
port: IntOrString::Int(config.environmentd_sql_port.into()),
1322+
}),
1323+
..Default::default()
13411324
};
13421325

13431326
let security_context = if config.enable_security_context {

0 commit comments

Comments
 (0)