Загрузка данных
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>