flink/values.yaml at main · base-setup/flink · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
default:
  imageRepository: flink
  imageTag: 1.19.1-scala_2.12-java17
  imagePullPolicy: IfNotPresent
  flinkVersion: &flinkVersion v1_19
  serviceAccount:
    create: true
    name: &serviceAccountName flink-cluster
    rbac:
      enabled: true
      rules:
        - apiGroups:
            - ""
          resources:
            - configmaps
            - pods
          verbs:
            - "*"
        - apiGroups:
            - apps
          resources:
            - deployments
          verbs:
            - "*"


sessionMode:
  enabled: false
  clusterName: &sessionClusterName flink-cluster
  flinkVersion: *flinkVersion
  restartNonce: 1
  flinkConfiguration: {}
  mode: native
  serviceAccount:
    create: false
    name: *serviceAccountName
    rbac:
      enabled: false
  jobManager:
    resource:
      memory: "1024m"
      cpu: 1
  taskManager:
    resource:
      cpu: 1
      memory: "1024m"
  ingress:
    template: "flink.k8s.io/{{namespace}}/{{name}}(/|$)(.*)"
    className: "nginx"
    annotations:
      nginx.ingress.kubernetes.io/rewrite-target: "/$2"
    labels: {}
    tls: []
sessionJobs:
  - name: job-example
    deploymentName: *sessionClusterName
    job:
      jarURI: https://repo1.maven.org/maven2/org/apache/flink/flink-examples-streaming_2.12/1.16.1/flink-examples-streaming_2.12-1.16.1.jar
      parallelism: 2
      upgradeMode: stateless
      entryClass: org.apache.flink.streaming.examples.statemachine.StateMachineExample

applicationMode:
  enabled: true
  application:
    - name: job-example
      flinkVersion: *flinkVersion
      restartNonce: 1
      flinkConfiguration: {}
      mode: native
      serviceAccount:
        create: false
        name: *serviceAccountName
        rbac:
          enabled: false
      volumes:
        - name: downloads
          emptyDir: { }
      containers:
        - name: flink-main-container
          volumeMounts:
            - mountPath: /opt/flink/downloads
              name: downloads
      jobManager:
        resource:
          memory: "1024m"
          cpu: 1
        initContainers:
          # Sample init container for fetching remote artifacts
          - name: busybox
            image: busybox:1.35.0
            volumeMounts:
              - mountPath: /opt/flink/downloads
                name: downloads
            command:
              - /bin/sh
              - -c
              - "wget -O /opt/flink/downloads/flink-examples-streaming.jar \
                    https://repo1.maven.org/maven2/org/apache/flink/flink-examples-streaming_2.12/1.16.1/flink-examples-streaming_2.12-1.16.1.jar"
      taskManager:
        resource:
          cpu: 1
          memory: "1024m"
      ingress:
        template: "flink.k8s.io/{{namespace}}/{{name}}(/|$)(.*)"
        className: "nginx"
        annotations:
          nginx.ingress.kubernetes.io/rewrite-target: "/$2"
        labels: {}
        tls: []
      job:
        jarURI: local:///opt/flink/downloads/flink-examples-streaming.jar
        parallelism: 2
        upgradeMode: stateless
        entryClass: org.apache.flink.streaming.examples.statemachine.StateMachineExample