feat: add opik

src/flink/Makefile

@@ -8,8 +8,21 @@ HELM_OCI_REGISTRY ?=
 HELM_OCI_NAMESPACE ?=
 HELM_OCI_USERNAME ?=
 HELM_OCI_PASSWORD ?=
-HELM_REPO_NAME ?= flink-operator
-HELM_REPO_URL ?= https://downloads.apache.org/flink/flink-kubernetes-operator-1.9.0/
-HELM_CHART_REPO ?= $(HELM_REPO_NAME)/flink-operator
+
+# Operator configuration
+OPERATOR_RELEASE_NAME ?= flink-operator
+OPERATOR_NAMESPACE ?= flink-operator
+OPERATOR_CHART_REPO ?= flink-operator/flink-operator
+OPERATOR_CHART_VERSION ?=
+OPERATOR_VALUES_FILE ?= ./values.yaml
+
+# Cluster configuration (Flink uses FlinkDeployment CR, installed via kubectl or separate chart)
+CLUSTER_RELEASE_NAME ?= flink-cluster
+CLUSTER_CHART_REPO ?= flink-operator/flink-cluster
+CLUSTER_VALUES_FILE ?= ./values-cluster.yaml
+
+# Enable CRD waiting
+WAIT_FOR_CRD ?= true
 
 include ../_template/base.mk
+include ../_template/operator.mk

src/flink/values-cluster.yaml

@@ -0,0 +1,33 @@
+# Flink Cluster Configuration (FlinkDeployment CR)
+# https://github.com/apache/flink-kubernetes-operator
+
+# Flink cluster name
+nameOverride: flink-cluster
+
+# Flink version
+flinkVersion: v1.19
+
+# Job configuration
+job:
+  jarURI: local:///opt/flink/examples/streaming/StateMachineExample.jar
+  parallelism: 2
+  upgradeMode: stateful
+  state: running
+
+# TaskManager configuration
+taskManager:
+  resource:
+    memory: 2048m
+    cpu: 1
+  replicas: 2
+
+# JobManager configuration
+jobManager:
+  resource:
+    memory: 1024m
+    cpu: 0.5
+  replicas: 1
+
+# Service configuration
+service:
+  type: ClusterIP