Rajat Ahuja
07/02/2023, 11:45 PMapiVersion: <http://flink.apache.org/v1beta1|flink.apache.org/v1beta1>
kind: FlinkDeployment
metadata:
name: session-deployment-only-example
spec:
image: flink:1.16
flinkVersion: v1_16
flinkConfiguration:
taskmanager.numberOfTaskSlots: "10"
serviceAccount: flink
jobManager:
resource:
memory: "2048m"
cpu: 1
taskManager:
resource:
memory: "2048m"
cpu: 1
JOb
apiVersion: <http://flink.apache.org/v1beta1|flink.apache.org/v1beta1>
kind: FlinkSessionJob
metadata:
name: session-job-only-example
spec:
deploymentName: session-deployment-only-example
job:
jarURI: file:///Users/rxahuja/Downloads/flink-examples-streaming_2.12-1.16.1-TopSpeedWindowing.jar
parallelism: 4
upgradeMode: stateless
status
kubectl get flinksessionjobs | grep session-job-only-example
basic-session-job-only-example UPGRADING
session-job-only-example UPGRADINGSamrat Deb
07/03/2023, 9:14 AM