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


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

metadata:
  name: basic-example
  namespace: default

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