Hi, @spserd , Interesting what you mentioned below: Flink 1.8.0 with NiFi artifacts (org.apache.nifi) in 1.11.6 - SUCCESS case Flink 1.14.3 with NiFi artifacts (org.apache.nifi) in 1.15.3 - FAILED case You upgraded Flink *and* NiFi versions at once. I don't think the Flink version would make a difference, but there's been some security changes in NiFi 1.15. I'm not sure how those would affect your case, but there's a possibility that they could require some additional configuration. The 401 error (authentication error) seen in your logs is probably related to the anonymous login. The anonymous login indicates to me that there's something wrong with your keystore. Are you able to share the keystore and truststore details I asked before? It's also weird that you had to add the truststore contents to the default Java cacerts. You should not need to do that if the truststore was being passed correctly to the job. Are you running your job in cluster mode? Is that on YARN? Wherever that job is running you must ensure that the keystore and truststore are available for the job to read them, at the right location. Could you please also share the command line that you use to submit the job? Cheers, André
... View more
