Загрузка данных


apiVersion: flink.apache.org/v1beta1
kind: FlinkBlueGreenDeployment

metadata:
  name: basic-example-bg
  namespace: default

spec:
  configuration:
    kubernetes.operator.bluegreen.deployment-deletion.delay: "30s"

  template:
    spec:
      image: flink:1.20
      flinkVersion: v1_20
      serviceAccount: flink

      flinkConfiguration:
        taskmanager.numberOfTaskSlots: "2"

      jobManager:
        resources:
          requests:
            memory: "2048Mi"
            cpu: "1"

      taskManager:
        resources:
          requests:
            memory: "2048Mi"
            cpu: "1"

      job:
        jarURI: local:///opt/flink/examples/streaming/StateMachineExample.jar
        parallelism: 2
        upgradeMode: stateless
        state: running