apiVersion: apps/v1
kind: Deployment
metadata:
  name: flink-taskmanager
spec:
  replicas: 2
  selector:
    matchLabels:
      app: flink
      component: taskmanager
  template:
    metadata:
      labels:
        app: flink
        component: taskmanager
    spec:
      containers:
      - name: taskmanager
        image: arm64v8/flink:1.14.6-scala_2.12
        # image: apache/flink:1.10.3
        # image: apache/flink:1.12.0-scala_2.11
        args: ["taskmanager"]
        ports:
        - containerPort: 6122
          name: rpc
        - containerPort: 6125
          name: query-state
        livenessProbe:
          tcpSocket:
            port: 6122
          initialDelaySeconds: 30
          periodSeconds: 60
        volumeMounts:
        - name: flink-config-volume
          mountPath: /opt/flink/conf/
        securityContext:
          runAsUser: 9999  # refers to user _flink_ from official flink image, change if necessary
#      - name: beam-worker-pool
#        #image: apache/beam_python3.7_sdk
#        image: arm64v8/flink:1.14.6-scala_2.12
#        args: ["--worker_pool"]
#        ports:
#        - containerPort: 50000
#          name: pool
#        livenessProbe:
#          tcpSocket:
#            port: 50000
#          initialDelaySeconds: 30
#          periodSeconds: 60
      volumes:
      - name: flink-config-volume
        configMap:
          name: flink-config
          items:
          - key: flink-conf.yaml
            path: flink-conf.yaml
          - key: log4j-console.properties
            path: log4j-console.properties