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


kubectl -n default get flinkdep basic-example -o yaml
apiVersion: flink.apache.org/v1beta1
kind: FlinkDeployment
metadata:
  annotations:
    kubectl.kubernetes.io/last-applied-configuration: |
      {"apiVersion":"flink.apache.org/v1beta1","kind":"FlinkDeployment","metadata":{"annotations":{},"name":"basic-example","namespace":"default"},"spec":{"flinkConfiguration":{"taskmanager.numberOfTaskSlots":"2"},"flinkVersion":"v1_20","image":"flink:1.20","job":{"jarURI":"local:///opt/flink/examples/streaming/StateMachineExample.jar","parallelism":2,"state":"running","upgradeMode":"stateless"},"jobManager":{"resources":{"requests":{"cpu":"1","memory":"2048Mi"}}},"serviceAccount":"flink","taskManager":{"resources":{"requests":{"cpu":"1","memory":"2048Mi"}}}}}
  creationTimestamp: "2026-10-15T12:23:24Z"
  finalizers:
  - flinkdeployments.flink.apache.org/finalizer
  generation: 1
  name: basic-example
  namespace: default
  resourceVersion: "1406485643"
  uid: 76935236-4f15-42bf-a9ea-74dc4d294675
spec:
  flinkConfiguration:
    taskmanager.numberOfTaskSlots: "2"
  flinkVersion: v1_20
  image: flink:1.20
  job:
    jarURI: local:///opt/flink/examples/streaming/StateMachineExample.jar
    parallelism: 2
    state: running
    upgradeMode: stateless
  jobManager:
    resources:
      requests:
        cpu: "1"
        memory: 2048Mi
  serviceAccount: flink
  taskManager:
    resources:
      requests:
        cpu: "1"
        memory: 2048Mi
status:
  clusterInfo: {}
  conditions:
  - lastTransitionTime: "2026-10-15T12:23:25.328986290Z"
    message: Job status RECONCILING
    reason: Reconciling
    status: "False"
    type: Running
  error: '{"type":"org.apache.flink.kubernetes.operator.exception.DeploymentFailedException","message":"pods
    \"basic-example-56c86f46f5-\" is forbidden: error looking up service account default/flink:
    serviceaccount \"flink\" not found","additionalMetadata":{"reason":"FailedCreate"},"throwableList":[]}'
  jobManagerDeploymentStatus: ERROR
  jobStatus:
    checkpointInfo:
      lastPeriodicCheckpointTimestamp: 0
    jobId: dfbda54e30ca61f091ea7d90a0f072da
    savepointInfo:
      lastPeriodicSavepointTimestamp: 0
      savepointHistory: []
    state: RECONCILING
  lifecycleState: DEPLOYED
  observedGeneration: 1
  reconciliationStatus:
    lastReconciledSpec: '{"spec":{"job":{"jarURI":"local:///opt/flink/examples/streaming/StateMachineExample.jar","parallelism":2,"entryClass":null,"args":[],"state":"running","savepointTriggerNonce":null,"initialSavepointPath":null,"checkpointTriggerNonce":null,"upgradeMode":"stateless","allowNonRestoredState":null,"savepointRedeployNonce":null,"autoscalerResetNonce":null},"restartNonce":null,"flinkConfiguration":{"taskmanager.numberOfTaskSlots":"2"},"image":"flink:1.20","imagePullPolicy":null,"serviceAccount":"flink","flinkVersion":"v1_20","ingress":null,"podTemplate":null,"jobManager":{"resource":null,"resources":{"requests":{"cpu":"1","memory":"2048Mi"}},"replicas":1,"podTemplate":null},"taskManager":{"resource":null,"resources":{"requests":{"cpu":"1","memory":"2048Mi"}},"replicas":null,"podTemplate":null},"logConfiguration":null,"mode":null},"resource_metadata":{"apiVersion":"flink.apache.org/v1beta1","firstDeployment":true}}'
    reconciliationTimestamp: 1792067005327
    state: DEPLOYED
  taskManager:
    labelSelector: component=taskmanager,app=basic-example
    replicas: 1

 kubectl -n default get pods -o wide
No resources found in default namespace.

kubectl -n default get events --sort-by='.lastTimestamp' | tail -n 30
LAST SEEN   TYPE      REASON         OBJECT                                MESSAGE
7m          Warning   FailedCreate   replicaset/basic-example-56c86f46f5   Error creating: pods "basic-example-56c86f46f5-" is forbidden: error looking up service account default/flink: serviceaccount "flink" not found

kubectl -n default describe deploy basic-example
Name:                   basic-example
Namespace:              default
CreationTimestamp:      Thu, 15 Oct 2026 15:23:25 +0300
Labels:                 app=basic-example
                        component=jobmanager
                        type=flink-native-kubernetes
Annotations:            deployment.kubernetes.io/revision: 1
                        flinkdeployment.flink.apache.org/generation: 1
Selector:               app=basic-example,component=jobmanager,type=flink-native-kubernetes
Replicas:               1 desired | 0 updated | 0 total | 0 available | 1 unavailable
StrategyType:           RollingUpdate
MinReadySeconds:        0
RollingUpdateStrategy:  25% max unavailable, 25% max surge
Pod Template:
  Labels:           app=basic-example
                    component=jobmanager
                    type=flink-native-kubernetes
  Annotations:      flinkdeployment.flink.apache.org/generation: 1
  Service Account:  flink
  Containers:
   flink-main-container:
    Image:       flink:1.20
    Ports:       8081/TCP (rest), 6123/TCP (jobmanager-rpc), 6124/TCP (blobserver)
    Host Ports:  0/TCP (rest), 0/TCP (jobmanager-rpc), 0/TCP (blobserver)
    Command:
      /docker-entrypoint.sh
    Args:
      bash
      -c
      kubernetes-jobmanager.sh kubernetes-application 
    Limits:
      cpu:     1
      memory:  2Gi
    Requests:
      cpu:     1
      memory:  2Gi
    Startup:   http-get http://:rest/config delay=0s timeout=1s period=1s successThreshold=1 failureThreshold=2147483647
    Environment:
      _POD_IP_ADDRESS:   (v1:status.podIP)
    Mounts:
      /opt/flink/artifacts from user-artifacts-volume (rw)
      /opt/flink/conf from flink-config-volume (rw)
  Volumes:
   user-artifacts-volume:
    Type:       EmptyDir (a temporary directory that shares a pod's lifetime)
    Medium:     
    SizeLimit:  <unset>
   flink-config-volume:
    Type:          ConfigMap (a volume populated by a ConfigMap)
    Name:          flink-config-basic-example
    Optional:      false
  Node-Selectors:  <none>
  Tolerations:     <none>
Conditions:
  Type             Status  Reason
  ----             ------  ------
  Available        False   MinimumReplicasUnavailable
  ReplicaFailure   True    FailedCreate
  Progressing      False   ProgressDeadlineExceeded
OldReplicaSets:    <none>
NewReplicaSet:     basic-example-56c86f46f5 (0/1 replicas created)
Events:            <none>