fix: add uncompress init container to fluentd drainer job (#1320)

kube-logging · May 20, 2023 · c5530fc · c5530fc
1 parent ebf7ec0
commit c5530fc
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/resources/fluentd/drainjob.go b/pkg/resources/fluentd/drainjob.go
@@ -39,6 +39,11 @@ func (r *Reconciler) drainerJobFor(pvc corev1.PersistentVolumeClaim) (*batchv1.J
 		containers = append(containers, *c)
 	}
 
+	var initContainers []corev1.Container
+	if i := generateInitContainer(r.Logging.Spec.FluentdSpec); i != nil {
+		initContainers = append(initContainers, *i)
+	}
+
 	spec := batchv1.JobSpec{
 		Template: corev1.PodTemplateSpec{
 			ObjectMeta: metav1.ObjectMeta{
@@ -49,6 +54,7 @@ func (r *Reconciler) drainerJobFor(pvc corev1.PersistentVolumeClaim) (*batchv1.J
 				Volumes:                   r.generateVolume(),
 				ServiceAccountName:        r.getServiceAccount(),
 				ImagePullSecrets:          r.Logging.Spec.FluentdSpec.Image.ImagePullSecrets,
+				InitContainers:            initContainers,
 				Containers:                containers,
 				NodeSelector:              r.Logging.Spec.FluentdSpec.NodeSelector,
 				Tolerations:               r.Logging.Spec.FluentdSpec.Tolerations,