Hi While using Flink Session deployed using K8-ope...
# troubleshooting
a
Hi While using Flink Session deployed using K8-operator with Flink version 1.17 When i am applying the file. The configuration is not getting applied on the JOB like the metrics.reporter.promgateway.jobName is not getting change or the taskmanager.memory.process.size is not getting change for a job Same is happening while running using flink-run command Cam someone please assist here what is the issue here
Copy code
apiVersion: flink.apache.org/v1beta1
kind: FlinkSessionJob
metadata:
  name: flink-job-test
spec:
  deploymentName: flink-session-cluster
  restartNonce: 11
  flinkConfiguration:
    # Flink Config Overrides
    kubernetes.operator.job.restart.failed: "true"
    jobmanager.memory.process.size: "2024m"
    taskmanager.numberOfTaskSlots: "4"
    taskmanager.memory.process.size: "4024m"
    metrics.reporters: "promgateway"
    metrics.reporter.promgateway.jobName: "flink_test_outside"
  job:
    jarURI: <https://repo1.maven.org/maven2/org/apache/flink/flink-python/1.17.1/flink-python-1.17.1.jar> # Note, this jarURI is actually a placeholder
    entryClass: "org.apache.flink.client.python.PythonDriver"
    args: ["-py", "/opt/flink/src/FlinkJob.py"]
    parallelism: 8
    upgradeMode: stateless
Can someone can assist on this issue