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


project:
  name: flink-test
  namespace: flink-test

monitoring:
  enabled: false

# В исходном tms-huawei-ekt-spb-cluster.yaml HA использует HDFS.
# Для первого запуска в отдельном namespace HA отключаем,
# чтобы не зависеть от HDFS/Kerberos.
ha:
  enabled: false
  flinkConfig: {}
  persistence:
    enabled: false

taskManager:
  resource:
    # Уменьшено относительно production (6g / 6 CPU) для тестового кластера.
    memory: "2048m"
    cpu: 1

jobManager:
  # Оставлен тот же Flink image, что и в исходном values.
  image: artifactory.tdp.corp.t2.ru:443/infrastructure-docker-repo/flink:1.19.3-scala_2.12-java8-hadoop-libs-bdops
  serviceAccount: flink
  flinkversion: v1_19
  replicas: 1

  resource:
    # Production: 4000m / 1 CPU.
    memory: "2048m"
    cpu: 1

  # В production используется nginx + LDAP. Для flink-test отключено.
  ingress:
    enabled: false

  flinkConfiguration:
    # Оставляем базовую модель исходного кластера, но уменьшаем число slots.
    taskmanager.numberOfTaskSlots: "2"
    taskmanager.memory.managed.fraction: 0.1

    # Autoscaler в исходном файле также выключен.
    job.autoscaler.enabled: "false"
    job.autoscaler.scaling.enabled: "true"
    job.autoscaler.metrics.window: "15m"
    job.autoscaler.stabilization.interval: "1m"
    job.autoscaler.target.utilization: "0.6"
    job.autoscaler.utilization.max: "0.8"
    job.autoscaler.utilization.min: "0.4"
    job.autoscaler.catch-up.duration: "30m"
    job.autoscaler.memory.tuning.enabled: "false"

    jobmanager.scheduler: adaptive
    pipeline.max-parallelism: "72"
    web.cancel.enable: true
    akka.framesize: 31457280b

    # Намеренно удалено по сравнению с production:
    # - jobConfig.hosts / remoteDir / hdfsSinkPath
    # - state.checkpoints.dir
    # - execution.checkpointing.savepoint-dir
    # - Hadoop/Kerberos settings
    # - security.kerberos.*

  podTemplate:
    kerberos:
      enabled: false

    main:
      ports: []
      volumeMounts: []
      lifecycle: {}
      env: []

    volumes: []

# Production FlinkSessionJob выключен. Сначала проверяем сам Session Cluster.
jobs: []

quota:
  enabled: false