pyflink gives the error message "Could not find a'KafkaClient' entry in the JAAS configuration. System property'java.security.auth.login.config' is not set"

[瞿叶奇]

  Hello! The error message I received when using pyflink to connect to Kafka is as follows:

 

My flink-conf.yaml has been configured with the necessary information, and my kerberos account is valid, as shown below：

My jaas.conf file is as follows:

I have also tried adding parameters, but it has not been resolved。Like below：

pyflink-shell.sh local  -Djava.security.auth.login.config=/opt/client2/Flink/flink/conf/jaas.conf

How can I solve it? No progress is currently stuck here.