Hi team, I deployed a Session Cluster on top of k8...
# troubleshooting
r
Hi team, I deployed a Session Cluster on top of k8s but when i try to run the job using the session Cluster using the name as defined it never gets to running state. Any idea what i might be doing wrong ? Any help would be appreciated Session Cluster
Copy code
apiVersion: <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
Copy code
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
Copy code
kubectl get flinksessionjobs | grep session-job-only-example
basic-session-job-only-example                UPGRADING
session-job-only-example                      UPGRADING
s
if you can add some debug logs , it would be easy to find the root cause