Hi all,

I am using Flink Kubernetes Operator to manage my Flink applications. I
have one issue when making changes in pipeline and I need to pass
--allowNonRestoredState configuration, but I cannot find how I can do this
using Flink Operator. Tried below method but didn't work:

 job:
        args:
        - --allowNonRestoredState
        entryClass: package.MainClass
        jarURI: local:///opt/flink/usrlib/app.jar
        parallelism: 6
        savepointTriggerNonce: 0
        state: running

Thank you

Reply via email to