<p>I just upgrade the Flink from version 1.10 to 1.11. In 1.11, Flink provides new features that users can deploy the job in Application Mode on Kubernetes.
<a href="https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deployment/kubernetes.html#deploy-session-cluster" rel="nofollow noreferrer">https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deployment/kubernetes.html#deploy-session-cluster</a></p>
<p>In V1.10, we start the Flink K8s cluster and then submit the job to Flink by run</p>
<pre><code>exec ./bin/flink run \
  -d \
  /streakerflink_deploy.jar \
    --arg1 blablabla
    --arg2 blablabla
    --arg3 blablabla
    ...
</code></pre>
<p>We pass the java arguments through this command.</p>
<p>But, in V1.11, if we run Application mode, we don't need to run the <code>flink run</code> command above. I am wondering how do we pass the arguments to Flink job in Application mode (aka Job Cluster)?</p>
<p>Any help will be appreciated!</p>

<p>Flink's application mode on Kubernetes is described in the <a href="https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deployment/native_kubernetes.html#flink-kubernetes-application" rel="nofollow noreferrer">docs</a>. You have to create a Docker image containing your job. The job can be executed using <code>./bin/flink run-application [...]</code> as described in the docs.</p>
