srujan kumar
07/31/2024, 7:07 AMflinkdeployment
manifest i see the job created and task running. But how can i resubmit the job as it says the configuration is unchanged on resubmitting the manifest. Do we have to always delete the flinkdeployment before resubmitting? Also I see the jobmanager continuously run even after the task is complete, is this expected behavior?
apiVersion: <http://flink.apache.org/v1beta1|flink.apache.org/v1beta1>
kind: FlinkDeployment
metadata:
name: wordcount
namespace: flink
spec:
image: flink:scala_2.12-java17
flinkVersion: v1_17
ingress:
template: "{{name}}.{{namespace}}.<http://flink.k8s.io|flink.k8s.io>"
flinkConfiguration:
taskmanager.numberOfTaskSlots: "2"
serviceAccount: flink
jobManager:
resource:
memory: "2048m"
cpu: 1
taskManager:
resource:
memory: "2048m"
cpu: 1
job:
jarURI: local:///opt/flink/examples/streaming/WordCount.jar
parallelism: 2
state: running
Sthiven
08/01/2024, 8:16 PM