#kubernetes #apache-flink
Вопрос:
Я новичок в Флинке и кубернетесе.
Я пытаюсь запустить кластер заданий Flink, используя облачную платформу Google flink-on-k8s-оператор. Я пытаюсь привести пример, в котором файл jar можно загрузить из ведра gcs, которое находится здесь. Я настроил секрет Kubernetes с помощью файла json учетной записи службы. Я правильно установил секретное имя в yaml здесь
Однако, когда я развертываю задание, initcontainer находится в состоянии ошибки. Когда я отлаживаю его, я получаю следующую ошибку в журнале
ServiceException: 401 Anonymous caller does not have storage.objects.get access to the Google Cloud Storage object.
Однако, когда я отправляю ту же банку из консоли пользовательского интерфейса диспетчера заданий, она работает нормально. Java — код в банке представляет собой программу минимального подсчета слов, которая получает текстовый файл из GCS и записывает количество слов обратно в gcs. Таким образом, кажется, что когда jar отправляется из пользовательского интерфейса, он может использовать секрет для аутентификации, получения файла образца и возврата результатов.
Пожалуйста, посоветуйте, чего мне не хватает в настройке.