Seraj Haqiqi
a36e72877d
- Add jarRef and jarPullSecret fields to FlinkJob CRD (jarUri/basicAuth deprecated) - OCI pull via go-containerregistry with dual auth (K8s pull secret + env vars) - Media type validation on pulled layers - Atomic status patches with runningJarRef/runningJarDigest tracking - NeedsUpgrade/RunningRef/RunningRefPatchData domain helpers - README with usage guide, pushing JARs, and GitHub Actions CI/CD workflow - CONTEXT.md domain glossary
27 lines
757 B
YAML
27 lines
757 B
YAML
# flink-job-instance.yaml
|
|
apiVersion: flink.logicamp.dev/v1alpha1
|
|
kind: FlinkJob
|
|
metadata:
|
|
name: my-flink-job
|
|
spec:
|
|
key: word-count
|
|
name: "Word Count Example"
|
|
entryClass: "tech.logicamp.logiline.FacilityEnrichment"
|
|
parallelism: 1
|
|
jarRef: "lcr.logicamp.tech/logiline/facility-enrichment:1.0.0"
|
|
jarPullSecret: "lcr-registry-creds"
|
|
# args accepts two formats:
|
|
# Map (recommended):
|
|
args:
|
|
kafka-host: kafka.pg-release:9092
|
|
kafka-group-id: batch-sales-config-dedup-processor
|
|
# List (also valid):
|
|
# args:
|
|
# - "--kafka-host"
|
|
# - kafka.pg-release:9092
|
|
# - "--kafka-group-id"
|
|
# - batch-sales-config-dedup-processor
|
|
flinkConfiguration:
|
|
taskmanager.numberOfTaskSlots: "1"
|
|
parallelism.default: "1"
|