@@ -218,11 +218,11 @@ func MakeHeadlessServiceName(serviceName string) string {
218218func MakeStatefulSet (objectMeta * metav1.ObjectMeta , replicas * int32 , downloaderImage string , container * corev1.Container ,
219219 volumes []corev1.Volume , labels map [string ]string , policy v1alpha1.PodPolicy , authConfig * v1alpha1.AuthConfig ,
220220 tlsConfig TLSConfig , pulsarConfig , authSecret , tlsSecret string , javaRuntime * v1alpha1.JavaRuntime ,
221- pythonRuntime * v1alpha1.PythonRuntime , goRuntime * v1alpha1.GoRuntime , env []corev1.EnvVar , name , logTopic , filebeatImage string ,
221+ pythonRuntime * v1alpha1.PythonRuntime , goRuntime * v1alpha1.GoRuntime , env []corev1.EnvVar , logTopic , filebeatImage string ,
222222 logTopicAgent v1alpha1.LogTopicAgent , definedVolumeMounts []corev1.VolumeMount , volumeClaimTemplates []corev1.PersistentVolumeClaim ,
223223 persistentVolumeClaimRetentionPolicy * appsv1.StatefulSetPersistentVolumeClaimRetentionPolicy ) * appsv1.StatefulSet {
224224
225- filebeatContainer := makeFilebeatContainer (definedVolumeMounts , env , name , logTopic , logTopicAgent , tlsConfig , authConfig , pulsarConfig , tlsSecret , authSecret , filebeatImage )
225+ filebeatContainer := makeFilebeatContainer (definedVolumeMounts , env , logTopic , logTopicAgent , tlsConfig , authConfig , pulsarConfig , tlsSecret , authSecret , filebeatImage )
226226
227227 volumeMounts := generateDownloaderVolumeMountsForDownloader (javaRuntime , pythonRuntime , goRuntime )
228228 var downloaderContainer * corev1.Container
@@ -2387,7 +2387,7 @@ func getSubscriptionNameOrDefault(subscription, tenant, namespace, name string)
23872387 return subscription
23882388}
23892389
2390- func makeFilebeatContainer (volumeMounts []corev1.VolumeMount , envVar []corev1.EnvVar , name string , logTopic string ,
2390+ func makeFilebeatContainer (volumeMounts []corev1.VolumeMount , envVar []corev1.EnvVar , logTopic string ,
23912391 agent v1alpha1.LogTopicAgent , tlsConfig TLSConfig , authConfig * v1alpha1.AuthConfig ,
23922392 pulsarConfig string , authSecret string , tlsSecret string , image string ) * corev1.Container {
23932393 if logTopic == "" || agent != v1alpha1 .SIDECAR {
@@ -2407,8 +2407,8 @@ func makeFilebeatContainer(volumeMounts []corev1.VolumeMount, envVar []corev1.En
24072407 Name : "logTopic" ,
24082408 Value : logTopic ,
24092409 }, corev1.EnvVar {
2410- Name : "logName " ,
2411- Value : name ,
2410+ Name : "POD_NAME " ,
2411+ ValueFrom : & corev1. EnvVarSource { FieldRef : & corev1. ObjectFieldSelector { FieldPath : "metadata. name" }} ,
24122412 })
24132413
24142414 if authConfig != nil {
0 commit comments