specify container name "main" to account for sidecar containers (#205)

spotify · Jan 13, 2022 · b71d0dc · b71d0dc
1 parent fb6277c
commit b71d0dc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/controllers/flinkcluster_util.go b/controllers/flinkcluster_util.go
@@ -520,7 +520,7 @@ func getPodLogs(clientset *kubernetes.Clientset, pod *corev1.Pod) (string, error
 	}
 	pods := clientset.CoreV1().Pods(pod.Namespace)
 
-	req := pods.GetLogs(pod.Name, &corev1.PodLogOptions{})
+	req := pods.GetLogs(pod.Name, &corev1.PodLogOptions{Container: "main"})
 	podLogs, err := req.Stream(context.TODO())
 	if err != nil {
 		return "", fmt.Errorf("failed to get logs for pod %s: %v", pod.Name, err)