У меня проблема с запуском приложения flink в кластере. Я получаю ошибку ниже, несмотря на все возможные варианты.
Caused by: java.lang.IllegalArgumentException: Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is /flink/client_jaas.conf
В основном мое приложение flink считывает данные из topi c A и находит события, соответствующие некоторой последовательности паттернов, и записывает выходные данные в topi c B. I Я не могу пройти проверку подлинности в кластере для чтения событий из темы А в кластере производительности.
Пожалуйста, дайте мне знать, что может быть не так