apiVersion: batch/v1
kind: Job
metadata:
  name: {{ include "flink-cdc-job.fullname" . }}
  namespace: {{ .Release.Namespace }}
  labels:
    {{- include "flink-cdc-job.labels" . | nindent 4 }}
spec:
  backoffLimit: 0
  template:
    spec:
      serviceAccountName: {{ include "flink-cdc-job.serviceAccountName" . }}
      containers:
        - name: submit
          image: {{ .Values.image.repository }}:{{ .Values.image.tag }}
          imagePullPolicy: {{ .Values.image.pullPolicy }}
          command: ["/bin/sh", "-c"]
          args:
            - |
              cd /opt/flink/flink-cdc-3.5.0
              ./bin/flink-cdc.sh \
                ./conf/pipeline.yaml \
                -Dexecution.checkpointing.interval={{ .Values.pipeline.checkpointInterval }} \
                -Drest.address={{ .Values.sessionCluster.restAddress }} \
                -Drest.port={{ .Values.sessionCluster.restPort }}
          volumeMounts:
            - name: pipeline-config
              mountPath: /opt/flink/flink-cdc-3.5.0/conf
      volumes:
        - name: pipeline-config
          configMap:
            name: {{ include "flink-cdc-job.fullname" . }}-config
      restartPolicy: Never