amarjeet pasrija
10/11/2023, 2:05 PMapiVersion: 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: statelessamarjeet pasrija
10/12/2023, 12:04 PM