Flink Fails on kafka NoClassDefFoundError

I have flink 1.14.4 job that have 2 kafka sources and 2 kafka sinks. After a time my job failed on the error

java.lang.NoClassDefFoundError: org/apache/kafka/common/security/scram/internals/ScramSaslClient$1

The error cause a crash loop that f开发者_开发问答link restart won't fix.

The only thing that seems to help is redeploy the flink environment and rerun the job. The environment run on a kubernetes cluster and deployed by helm and argoccd

Any help will be appreciated