Mohammadreza Khani
830e265162
use minio s3 for savepoint and checkpoint path separate task-manager, job-manager and operator use statefulset for task-manager to handle replication support basic credential for download jar request update to flink 1.20.1
16 lines
546 B
YAML
16 lines
546 B
YAML
# flink-job-instance.yaml
|
|
apiVersion: flink.logicamp.tech/v1alpha1
|
|
kind: FlinkJob
|
|
metadata:
|
|
name: my-flink-job
|
|
spec:
|
|
key: word-count
|
|
name: "Word Count Example"
|
|
entryClass: "tech.logicamp.logiline.FacilityEnrichment"
|
|
parallelism: 1
|
|
jarUri: "https://git.logicamp.tech/api/packages/logiline/generic/facility-enrichment/1.0.0/facility-enrichment.jar"
|
|
jarURIBasicAuthUsername: logiline-actrunner
|
|
jarURIBasicAuthPassword: daeweeb7ohpaiw3oojiCoong
|
|
flinkConfiguration:
|
|
taskmanager.numberOfTaskSlots: "1"
|
|
parallelism.default: "1" |