source commons files source engines files source kubeblocks files `kubectl get namespace | grep ns-vywof ` `kubectl create namespace ns-vywof` namespace/ns-vywof created create namespace ns-vywof done download kbcli `gh release list --repo apecloud/kbcli --limit 100 | (grep "0.9" || true)` `curl -fsSL https://kubeblocks.io/installer/install_cli.sh | bash -s v0.9.4-beta.1` Your system is linux_amd64 Installing kbcli ... Downloading ... % Total % Received % Xferd Average Speed Time Time Time Current Dload Upload Total Spent Left Speed 0 0 0 0 0 0 0 0 --:--:-- --:--:-- --:--:-- 0 0 0 0 0 0 0 0 0 --:--:-- --:--:-- --:--:-- 0 100 32.1M 100 32.1M 0 0 54.4M 0 --:--:-- --:--:-- --:--:-- 54.4M kbcli installed successfully. Kubernetes: v1.32.5-eks-5d4a308 KubeBlocks: 0.9.4 kbcli: 0.9.4-beta.1 WARNING: version difference between kbcli (0.9.4-beta.1) and kubeblocks (0.9.4) Make sure your docker service is running and begin your journey with kbcli: kbcli playground init For more information on how to get started, please visit: https://kubeblocks.io download kbcli v0.9.4-beta.1 done Kubernetes: v1.32.5-eks-5d4a308 KubeBlocks: 0.9.4 kbcli: 0.9.4-beta.1 WARNING: version difference between kbcli (0.9.4-beta.1) and kubeblocks (0.9.4) Kubernetes Env: v1.32.5-eks-5d4a308 POD_RESOURCES: No resources found found default storage class: gp3 kubeblocks version is:0.9.4 skip upgrade kubeblocks Error: no repositories to show helm repo add chaos-mesh https://charts.chaos-mesh.org "chaos-mesh" has been added to your repositories add helm chart repo chaos-mesh success chaos mesh already installed check cluster definition set component name:jobmanager set component version No resources found no component version found unsupported component definition not found component version set replicas first:1 set replicas third:1 set minimum cmpv service version set minimum cmpv service version replicas:1 REPORT_COUNT:1 CLUSTER_TOPOLOGY: Not found topology in cluster definition flink LIMIT_CPU:0.1 LIMIT_MEMORY:1 storage size: 1 No resources found in ns-vywof namespace. termination_policy:DoNotTerminate create 1 replica DoNotTerminate flink cluster check cluster version check cluster definition apiVersion: apps.kubeblocks.io/v1alpha1 kind: Cluster metadata: name: flink-decauo namespace: ns-vywof spec: clusterDefinitionRef: flink clusterVersionRef: flink-1.16 terminationPolicy: DoNotTerminate componentSpecs: - name: jobmanager componentDefRef: jobmanager replicas: 1 resources: requests: cpu: 100m memory: 1Gi limits: cpu: 100m memory: 1Gi - name: taskmanager componentDefRef: taskmanager replicas: 1 resources: requests: cpu: 100m memory: 1Gi limits: cpu: 100m memory: 1Gi `kubectl apply -f test_create_flink-decauo.yaml` cluster.apps.kubeblocks.io/flink-decauo created apply test_create_flink-decauo.yaml Success `rm -rf test_create_flink-decauo.yaml` check cluster status `kbcli cluster list flink-decauo --show-labels --namespace ns-vywof ` NAME NAMESPACE CLUSTER-DEFINITION VERSION TERMINATION-POLICY STATUS CREATED-TIME LABELS flink-decauo ns-vywof flink flink-1.16 DoNotTerminate Jun 19,2025 18:13 UTC+0800 clusterdefinition.kubeblocks.io/name=flink,clusterversion.kubeblocks.io/name=flink-1.16 cluster_status: check cluster status done cluster_status:Running check pod status `kbcli cluster list-instances flink-decauo --namespace ns-vywof ` NAME NAMESPACE CLUSTER COMPONENT STATUS ROLE ACCESSMODE AZ CPU(REQUEST/LIMIT) MEMORY(REQUEST/LIMIT) STORAGE NODE CREATED-TIME flink-decauo-jobmanager-0 ns-vywof flink-decauo jobmanager Running us-west-2a 100m / 100m 1Gi / 1Gi ip-172-31-14-103.us-west-2.compute.internal/172.31.14.103 Jun 19,2025 18:13 UTC+0800 flink-decauo-taskmanager-0 ns-vywof flink-decauo taskmanager Running us-west-2a 100m / 100m 1Gi / 1Gi ip-172-31-3-103.us-west-2.compute.internal/172.31.3.103 Jun 19,2025 18:13 UTC+0800 check pod status done check cluster connect `echo "curl -s flink-decauo-jobmanager.ns-vywof.svc.cluster.local:8081" | kubectl exec -it flink-decauo-jobmanager-0 --namespace ns-vywof -- bash` connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... check cluster connect done `kubectl get secrets -l app.kubernetes.io/instance=flink-decauo` `kubectl get secrets flink-decauo-conn-credential -o jsonpath="***.data.username***"` `kubectl get secrets flink-decauo-conn-credential -o jsonpath="***.data.password***"` `kubectl get secrets flink-decauo-conn-credential -o jsonpath="***.data.port***"` DB_USERNAME:;DB_PASSWORD:;DB_PORT:8081;DB_DATABASE: There is no password in Type: 39. describe cluster `kbcli cluster describe flink-decauo --namespace ns-vywof ` Name: flink-decauo Created Time: Jun 19,2025 18:13 UTC+0800 NAMESPACE CLUSTER-DEFINITION VERSION STATUS TERMINATION-POLICY ns-vywof flink flink-1.16 Running DoNotTerminate Endpoints: COMPONENT MODE INTERNAL EXTERNAL jobmanager ReadWrite flink-decauo-jobmanager.ns-vywof.svc.cluster.local:6123 flink-decauo-jobmanager.ns-vywof.svc.cluster.local:8081 flink-decauo-jobmanager.ns-vywof.svc.cluster.local:6124 Topology: COMPONENT INSTANCE ROLE STATUS AZ NODE CREATED-TIME jobmanager flink-decauo-jobmanager-0 Running us-west-2a ip-172-31-14-103.us-west-2.compute.internal/172.31.14.103 Jun 19,2025 18:13 UTC+0800 taskmanager flink-decauo-taskmanager-0 Running us-west-2a ip-172-31-3-103.us-west-2.compute.internal/172.31.3.103 Jun 19,2025 18:13 UTC+0800 Resources Allocation: COMPONENT DEDICATED CPU(REQUEST/LIMIT) MEMORY(REQUEST/LIMIT) STORAGE-SIZE STORAGE-CLASS jobmanager false 100m / 100m 1Gi / 1Gi taskmanager false 100m / 100m 1Gi / 1Gi Images: COMPONENT TYPE IMAGE jobmanager jobmanager docker.io/apecloud/flink:1.16 taskmanager taskmanager docker.io/apecloud/flink:1.16 Show cluster events: kbcli cluster list-events -n ns-vywof flink-decauo `kbcli cluster label flink-decauo app.kubernetes.io/instance- --namespace ns-vywof ` label "app.kubernetes.io/instance" not found. `kbcli cluster label flink-decauo app.kubernetes.io/instance=flink-decauo --namespace ns-vywof ` `kbcli cluster label flink-decauo --list --namespace ns-vywof ` NAME NAMESPACE LABELS flink-decauo ns-vywof app.kubernetes.io/instance=flink-decauo clusterdefinition.kubeblocks.io/name=flink clusterversion.kubeblocks.io/name=flink-1.16 label cluster app.kubernetes.io/instance=flink-decauo Success `kbcli cluster label case.name=kbcli.test1 -l app.kubernetes.io/instance=flink-decauo --namespace ns-vywof ` `kbcli cluster label flink-decauo --list --namespace ns-vywof ` NAME NAMESPACE LABELS flink-decauo ns-vywof app.kubernetes.io/instance=flink-decauo case.name=kbcli.test1 clusterdefinition.kubeblocks.io/name=flink clusterversion.kubeblocks.io/name=flink-1.16 label cluster case.name=kbcli.test1 Success `kbcli cluster label flink-decauo case.name=kbcli.test2 --overwrite --namespace ns-vywof ` `kbcli cluster label flink-decauo --list --namespace ns-vywof ` NAME NAMESPACE LABELS flink-decauo ns-vywof app.kubernetes.io/instance=flink-decauo case.name=kbcli.test2 clusterdefinition.kubeblocks.io/name=flink clusterversion.kubeblocks.io/name=flink-1.16 label cluster case.name=kbcli.test2 Success `kbcli cluster label flink-decauo case.name- --namespace ns-vywof ` `kbcli cluster label flink-decauo --list --namespace ns-vywof ` NAME NAMESPACE LABELS flink-decauo ns-vywof app.kubernetes.io/instance=flink-decauo clusterdefinition.kubeblocks.io/name=flink clusterversion.kubeblocks.io/name=flink-1.16 delete cluster label case.name Success cluster connect `echo "curl -s flink-decauo-jobmanager.ns-vywof.svc.cluster.local:8081" | kubectl exec -it flink-decauo-jobmanager-0 --namespace ns-vywof -- bash ` Unable to use a TTY - input is not a terminal or the right kind of file Apache Flink Web Dashboard connect cluster Success `kubectl get secrets -l app.kubernetes.io/instance=flink-decauo` `kubectl get secrets flink-decauo-conn-credential -o jsonpath="***.data.username***"` `kubectl get secrets flink-decauo-conn-credential -o jsonpath="***.data.password***"` `kubectl get secrets flink-decauo-conn-credential -o jsonpath="***.data.port***"` DB_USERNAME:;DB_PASSWORD:;DB_PORT:8081;DB_DATABASE: `flink run /opt/flink/examples/batch/EnumTriangles.jar` Unable to use a TTY - input is not a terminal or the right kind of file exec return msg:Executing EnumTriangles example with default edges data set. Use --edges to specify file input. Printing result to stdout. Use --output to specify output path. Job has been submitted with JobID 6ae77511a00cec276e671d71326e6c91 Program execution finished Job with JobID 6ae77511a00cec276e671d71326e6c91 has finished. Job Runtime: 34322 ms Accumulator Results: - 8e932fe238ec613ffc4e67bc3707b0ad (java.util.ArrayList) [4 elements] (1,2,3) (1,2,5) (1,3,4) (3,7,8) Program execution finished check component taskmanager exists `kubectl get components -l app.kubernetes.io/instance=flink-decauo,apps.kubeblocks.io/component-name=taskmanager --namespace ns-vywof | (grep "taskmanager" || true )` cluster vscale check cluster status before ops check cluster status done cluster_status:Running `kbcli cluster vscale flink-decauo --auto-approve --force=true --components taskmanager --cpu 200m --memory 1.1Gi --namespace ns-vywof ` OpsRequest flink-decauo-verticalscaling-p8ckf created successfully, you can view the progress: kbcli cluster describe-ops flink-decauo-verticalscaling-p8ckf -n ns-vywof check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-verticalscaling-p8ckf ns-vywof VerticalScaling flink-decauo taskmanager Pending -/- Jun 19,2025 18:18 UTC+0800 ops_status:flink-decauo-verticalscaling-p8ckf ns-vywof VerticalScaling flink-decauo taskmanager Creating -/- Jun 19,2025 18:18 UTC+0800 check cluster status `kbcli cluster list flink-decauo --show-labels --namespace ns-vywof ` NAME NAMESPACE CLUSTER-DEFINITION VERSION TERMINATION-POLICY STATUS CREATED-TIME LABELS flink-decauo ns-vywof flink flink-1.16 DoNotTerminate Updating Jun 19,2025 18:13 UTC+0800 app.kubernetes.io/instance=flink-decauo,clusterdefinition.kubeblocks.io/name=flink,clusterversion.kubeblocks.io/name=flink-1.16 cluster_status:Updating cluster_status:Updating check cluster status done cluster_status:Running check pod status `kbcli cluster list-instances flink-decauo --namespace ns-vywof ` NAME NAMESPACE CLUSTER COMPONENT STATUS ROLE ACCESSMODE AZ CPU(REQUEST/LIMIT) MEMORY(REQUEST/LIMIT) STORAGE NODE CREATED-TIME flink-decauo-jobmanager-0 ns-vywof flink-decauo jobmanager Running us-west-2a 100m / 100m 1Gi / 1Gi ip-172-31-14-103.us-west-2.compute.internal/172.31.14.103 Jun 19,2025 18:13 UTC+0800 flink-decauo-taskmanager-0 ns-vywof flink-decauo taskmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-10-42.us-west-2.compute.internal/172.31.10.42 Jun 19,2025 18:18 UTC+0800 check pod status done check cluster connect `echo "curl -s flink-decauo-jobmanager.ns-vywof.svc.cluster.local:8081" | kubectl exec -it flink-decauo-jobmanager-0 --namespace ns-vywof -- bash` check cluster connect done check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-verticalscaling-p8ckf ns-vywof VerticalScaling flink-decauo taskmanager Succeed 1/1 Jun 19,2025 18:18 UTC+0800 check ops status done ops_status:flink-decauo-verticalscaling-p8ckf ns-vywof VerticalScaling flink-decauo taskmanager Succeed 1/1 Jun 19,2025 18:18 UTC+0800 `kubectl patch -p '***"metadata":***"finalizers":[]***' --type=merge opsrequests flink-decauo-verticalscaling-p8ckf --namespace ns-vywof ` opsrequest.apps.kubeblocks.io/flink-decauo-verticalscaling-p8ckf patched `kbcli cluster delete-ops --name flink-decauo-verticalscaling-p8ckf --force --auto-approve --namespace ns-vywof ` OpsRequest flink-decauo-verticalscaling-p8ckf deleted cluster vscale check cluster status before ops check cluster status done cluster_status:Running `kbcli cluster vscale flink-decauo --auto-approve --force=true --components jobmanager --cpu 200m --memory 1.1Gi --namespace ns-vywof ` OpsRequest flink-decauo-verticalscaling-8rr8q created successfully, you can view the progress: kbcli cluster describe-ops flink-decauo-verticalscaling-8rr8q -n ns-vywof check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-verticalscaling-8rr8q ns-vywof VerticalScaling flink-decauo jobmanager Running 0/1 Jun 19,2025 18:19 UTC+0800 check cluster status `kbcli cluster list flink-decauo --show-labels --namespace ns-vywof ` NAME NAMESPACE CLUSTER-DEFINITION VERSION TERMINATION-POLICY STATUS CREATED-TIME LABELS flink-decauo ns-vywof flink flink-1.16 DoNotTerminate Running Jun 19,2025 18:13 UTC+0800 app.kubernetes.io/instance=flink-decauo,clusterdefinition.kubeblocks.io/name=flink,clusterversion.kubeblocks.io/name=flink-1.16 check cluster status done cluster_status:Running check pod status `kbcli cluster list-instances flink-decauo --namespace ns-vywof ` NAME NAMESPACE CLUSTER COMPONENT STATUS ROLE ACCESSMODE AZ CPU(REQUEST/LIMIT) MEMORY(REQUEST/LIMIT) STORAGE NODE CREATED-TIME flink-decauo-jobmanager-0 ns-vywof flink-decauo jobmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-10-42.us-west-2.compute.internal/172.31.10.42 Jun 19,2025 18:19 UTC+0800 flink-decauo-taskmanager-0 ns-vywof flink-decauo taskmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-10-42.us-west-2.compute.internal/172.31.10.42 Jun 19,2025 18:18 UTC+0800 check pod status done check cluster connect `echo "curl -s flink-decauo-jobmanager.ns-vywof.svc.cluster.local:8081" | kubectl exec -it flink-decauo-jobmanager-0 --namespace ns-vywof -- bash` connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... check cluster connect done check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-verticalscaling-8rr8q ns-vywof VerticalScaling flink-decauo jobmanager Succeed 1/1 Jun 19,2025 18:19 UTC+0800 check ops status done ops_status:flink-decauo-verticalscaling-8rr8q ns-vywof VerticalScaling flink-decauo jobmanager Succeed 1/1 Jun 19,2025 18:19 UTC+0800 `kubectl patch -p '***"metadata":***"finalizers":[]***' --type=merge opsrequests flink-decauo-verticalscaling-8rr8q --namespace ns-vywof ` opsrequest.apps.kubeblocks.io/flink-decauo-verticalscaling-8rr8q patched `kbcli cluster delete-ops --name flink-decauo-verticalscaling-8rr8q --force --auto-approve --namespace ns-vywof ` OpsRequest flink-decauo-verticalscaling-8rr8q deleted cluster stop check cluster status before ops check cluster status done cluster_status:Running `kbcli cluster stop flink-decauo --auto-approve --force=true --namespace ns-vywof ` OpsRequest flink-decauo-stop-qpqwr created successfully, you can view the progress: kbcli cluster describe-ops flink-decauo-stop-qpqwr -n ns-vywof check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-stop-qpqwr ns-vywof Stop flink-decauo jobmanager,taskmanager Running 0/2 Jun 19,2025 18:20 UTC+0800 check cluster status `kbcli cluster list flink-decauo --show-labels --namespace ns-vywof ` NAME NAMESPACE CLUSTER-DEFINITION VERSION TERMINATION-POLICY STATUS CREATED-TIME LABELS flink-decauo ns-vywof flink flink-1.16 DoNotTerminate Stopped Jun 19,2025 18:13 UTC+0800 app.kubernetes.io/instance=flink-decauo,clusterdefinition.kubeblocks.io/name=flink,clusterversion.kubeblocks.io/name=flink-1.16 check cluster status done cluster_status:Stopped check pod status `kbcli cluster list-instances flink-decauo --namespace ns-vywof ` NAME NAMESPACE CLUSTER COMPONENT STATUS ROLE ACCESSMODE AZ CPU(REQUEST/LIMIT) MEMORY(REQUEST/LIMIT) STORAGE NODE CREATED-TIME check pod status done check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-stop-qpqwr ns-vywof Stop flink-decauo jobmanager,taskmanager Succeed 2/2 Jun 19,2025 18:20 UTC+0800 check ops status done ops_status:flink-decauo-stop-qpqwr ns-vywof Stop flink-decauo jobmanager,taskmanager Succeed 2/2 Jun 19,2025 18:20 UTC+0800 `kubectl patch -p '***"metadata":***"finalizers":[]***' --type=merge opsrequests flink-decauo-stop-qpqwr --namespace ns-vywof ` opsrequest.apps.kubeblocks.io/flink-decauo-stop-qpqwr patched `kbcli cluster delete-ops --name flink-decauo-stop-qpqwr --force --auto-approve --namespace ns-vywof ` OpsRequest flink-decauo-stop-qpqwr deleted cluster start check cluster status before ops check cluster status done cluster_status:Stopped `kbcli cluster start flink-decauo --force=true --namespace ns-vywof ` OpsRequest flink-decauo-start-qwb8b created successfully, you can view the progress: kbcli cluster describe-ops flink-decauo-start-qwb8b -n ns-vywof check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-start-qwb8b ns-vywof Start flink-decauo Pending -/- Jun 19,2025 18:21 UTC+0800 ops_status:flink-decauo-start-qwb8b ns-vywof Start flink-decauo Creating -/- Jun 19,2025 18:21 UTC+0800 ops_status:flink-decauo-start-qwb8b ns-vywof Start flink-decauo jobmanager,taskmanager Succeed 2/2 Jun 19,2025 18:21 UTC+0800 ops Start Succeed or Failed Soon check cluster status `kbcli cluster list flink-decauo --show-labels --namespace ns-vywof ` NAME NAMESPACE CLUSTER-DEFINITION VERSION TERMINATION-POLICY STATUS CREATED-TIME LABELS flink-decauo ns-vywof flink flink-1.16 DoNotTerminate Running Jun 19,2025 18:13 UTC+0800 app.kubernetes.io/instance=flink-decauo,clusterdefinition.kubeblocks.io/name=flink,clusterversion.kubeblocks.io/name=flink-1.16 check cluster status done cluster_status:Running check pod status `kbcli cluster list-instances flink-decauo --namespace ns-vywof ` NAME NAMESPACE CLUSTER COMPONENT STATUS ROLE ACCESSMODE AZ CPU(REQUEST/LIMIT) MEMORY(REQUEST/LIMIT) STORAGE NODE CREATED-TIME flink-decauo-jobmanager-0 ns-vywof flink-decauo jobmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-3-103.us-west-2.compute.internal/172.31.3.103 Jun 19,2025 18:21 UTC+0800 flink-decauo-taskmanager-0 ns-vywof flink-decauo taskmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-10-42.us-west-2.compute.internal/172.31.10.42 Jun 19,2025 18:21 UTC+0800 check pod status done check cluster connect `echo "curl -s flink-decauo-jobmanager.ns-vywof.svc.cluster.local:8081" | kubectl exec -it flink-decauo-jobmanager-0 --namespace ns-vywof -- bash` connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... check cluster connect done check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-start-qwb8b ns-vywof Start flink-decauo jobmanager,taskmanager Succeed 2/2 Jun 19,2025 18:21 UTC+0800 check ops status done ops_status:flink-decauo-start-qwb8b ns-vywof Start flink-decauo jobmanager,taskmanager Succeed 2/2 Jun 19,2025 18:21 UTC+0800 `kubectl patch -p '***"metadata":***"finalizers":[]***' --type=merge opsrequests flink-decauo-start-qwb8b --namespace ns-vywof ` opsrequest.apps.kubeblocks.io/flink-decauo-start-qwb8b patched `kbcli cluster delete-ops --name flink-decauo-start-qwb8b --force --auto-approve --namespace ns-vywof ` OpsRequest flink-decauo-start-qwb8b deleted check component taskmanager exists `kubectl get components -l app.kubernetes.io/instance=flink-decauo,apps.kubeblocks.io/component-name=taskmanager --namespace ns-vywof | (grep "taskmanager" || true )` cluster hscale check cluster status before ops check cluster status done cluster_status:Running No resources found in flink-decauo namespace. `kbcli cluster hscale flink-decauo --auto-approve --force=true --components taskmanager --replicas 2 --namespace ns-vywof ` OpsRequest flink-decauo-horizontalscaling-pmlb2 created successfully, you can view the progress: kbcli cluster describe-ops flink-decauo-horizontalscaling-pmlb2 -n ns-vywof check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-horizontalscaling-pmlb2 ns-vywof HorizontalScaling flink-decauo taskmanager Running 0/1 Jun 19,2025 18:22 UTC+0800 check cluster status `kbcli cluster list flink-decauo --show-labels --namespace ns-vywof ` NAME NAMESPACE CLUSTER-DEFINITION VERSION TERMINATION-POLICY STATUS CREATED-TIME LABELS flink-decauo ns-vywof flink flink-1.16 DoNotTerminate Running Jun 19,2025 18:13 UTC+0800 app.kubernetes.io/instance=flink-decauo,clusterdefinition.kubeblocks.io/name=flink,clusterversion.kubeblocks.io/name=flink-1.16 check cluster status done cluster_status:Running check pod status `kbcli cluster list-instances flink-decauo --namespace ns-vywof ` NAME NAMESPACE CLUSTER COMPONENT STATUS ROLE ACCESSMODE AZ CPU(REQUEST/LIMIT) MEMORY(REQUEST/LIMIT) STORAGE NODE CREATED-TIME flink-decauo-jobmanager-0 ns-vywof flink-decauo jobmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-3-103.us-west-2.compute.internal/172.31.3.103 Jun 19,2025 18:21 UTC+0800 flink-decauo-taskmanager-0 ns-vywof flink-decauo taskmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-10-42.us-west-2.compute.internal/172.31.10.42 Jun 19,2025 18:21 UTC+0800 flink-decauo-taskmanager-1 ns-vywof flink-decauo taskmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-3-103.us-west-2.compute.internal/172.31.3.103 Jun 19,2025 18:22 UTC+0800 check pod status done check cluster connect `echo "curl -s flink-decauo-jobmanager.ns-vywof.svc.cluster.local:8081" | kubectl exec -it flink-decauo-jobmanager-0 --namespace ns-vywof -- bash` check cluster connect done No resources found in flink-decauo namespace. check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-horizontalscaling-pmlb2 ns-vywof HorizontalScaling flink-decauo taskmanager Succeed 1/1 Jun 19,2025 18:22 UTC+0800 check ops status done ops_status:flink-decauo-horizontalscaling-pmlb2 ns-vywof HorizontalScaling flink-decauo taskmanager Succeed 1/1 Jun 19,2025 18:22 UTC+0800 `kubectl patch -p '***"metadata":***"finalizers":[]***' --type=merge opsrequests flink-decauo-horizontalscaling-pmlb2 --namespace ns-vywof ` opsrequest.apps.kubeblocks.io/flink-decauo-horizontalscaling-pmlb2 patched `kbcli cluster delete-ops --name flink-decauo-horizontalscaling-pmlb2 --force --auto-approve --namespace ns-vywof ` OpsRequest flink-decauo-horizontalscaling-pmlb2 deleted check component taskmanager exists `kubectl get components -l app.kubernetes.io/instance=flink-decauo,apps.kubeblocks.io/component-name=taskmanager --namespace ns-vywof | (grep "taskmanager" || true )` cluster hscale check cluster status before ops check cluster status done cluster_status:Running No resources found in flink-decauo namespace. `kbcli cluster hscale flink-decauo --auto-approve --force=true --components taskmanager --replicas 1 --namespace ns-vywof ` OpsRequest flink-decauo-horizontalscaling-k46wc created successfully, you can view the progress: kbcli cluster describe-ops flink-decauo-horizontalscaling-k46wc -n ns-vywof check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-horizontalscaling-k46wc ns-vywof HorizontalScaling flink-decauo taskmanager Running 0/1 Jun 19,2025 18:22 UTC+0800 check cluster status `kbcli cluster list flink-decauo --show-labels --namespace ns-vywof ` NAME NAMESPACE CLUSTER-DEFINITION VERSION TERMINATION-POLICY STATUS CREATED-TIME LABELS flink-decauo ns-vywof flink flink-1.16 DoNotTerminate Running Jun 19,2025 18:13 UTC+0800 app.kubernetes.io/instance=flink-decauo,clusterdefinition.kubeblocks.io/name=flink,clusterversion.kubeblocks.io/name=flink-1.16 check cluster status done cluster_status:Running check pod status `kbcli cluster list-instances flink-decauo --namespace ns-vywof ` NAME NAMESPACE CLUSTER COMPONENT STATUS ROLE ACCESSMODE AZ CPU(REQUEST/LIMIT) MEMORY(REQUEST/LIMIT) STORAGE NODE CREATED-TIME flink-decauo-jobmanager-0 ns-vywof flink-decauo jobmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-3-103.us-west-2.compute.internal/172.31.3.103 Jun 19,2025 18:21 UTC+0800 flink-decauo-taskmanager-0 ns-vywof flink-decauo taskmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-10-42.us-west-2.compute.internal/172.31.10.42 Jun 19,2025 18:21 UTC+0800 check pod status done check cluster connect `echo "curl -s flink-decauo-jobmanager.ns-vywof.svc.cluster.local:8081" | kubectl exec -it flink-decauo-jobmanager-0 --namespace ns-vywof -- bash` check cluster connect done No resources found in flink-decauo namespace. check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-horizontalscaling-k46wc ns-vywof HorizontalScaling flink-decauo taskmanager Succeed 1/1 Jun 19,2025 18:22 UTC+0800 check ops status done ops_status:flink-decauo-horizontalscaling-k46wc ns-vywof HorizontalScaling flink-decauo taskmanager Succeed 1/1 Jun 19,2025 18:22 UTC+0800 `kubectl patch -p '***"metadata":***"finalizers":[]***' --type=merge opsrequests flink-decauo-horizontalscaling-k46wc --namespace ns-vywof ` opsrequest.apps.kubeblocks.io/flink-decauo-horizontalscaling-k46wc patched `kbcli cluster delete-ops --name flink-decauo-horizontalscaling-k46wc --force --auto-approve --namespace ns-vywof ` OpsRequest flink-decauo-horizontalscaling-k46wc deleted 8 cluster restart check cluster status before ops check cluster status done cluster_status:Running `kbcli cluster restart flink-decauo --auto-approve --force=true --namespace ns-vywof ` OpsRequest flink-decauo-restart-lqgc7 created successfully, you can view the progress: kbcli cluster describe-ops flink-decauo-restart-lqgc7 -n ns-vywof check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-restart-lqgc7 ns-vywof Restart flink-decauo jobmanager,taskmanager Running 0/2 Jun 19,2025 18:23 UTC+0800 check cluster status `kbcli cluster list flink-decauo --show-labels --namespace ns-vywof ` NAME NAMESPACE CLUSTER-DEFINITION VERSION TERMINATION-POLICY STATUS CREATED-TIME LABELS flink-decauo ns-vywof flink flink-1.16 DoNotTerminate Running Jun 19,2025 18:13 UTC+0800 app.kubernetes.io/instance=flink-decauo,clusterdefinition.kubeblocks.io/name=flink,clusterversion.kubeblocks.io/name=flink-1.16 check cluster status done cluster_status:Running check pod status `kbcli cluster list-instances flink-decauo --namespace ns-vywof ` NAME NAMESPACE CLUSTER COMPONENT STATUS ROLE ACCESSMODE AZ CPU(REQUEST/LIMIT) MEMORY(REQUEST/LIMIT) STORAGE NODE CREATED-TIME flink-decauo-jobmanager-0 ns-vywof flink-decauo jobmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-3-103.us-west-2.compute.internal/172.31.3.103 Jun 19,2025 18:23 UTC+0800 flink-decauo-taskmanager-0 ns-vywof flink-decauo taskmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-10-42.us-west-2.compute.internal/172.31.10.42 Jun 19,2025 18:23 UTC+0800 check pod status done check cluster connect `echo "curl -s flink-decauo-jobmanager.ns-vywof.svc.cluster.local:8081" | kubectl exec -it flink-decauo-jobmanager-0 --namespace ns-vywof -- bash` connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... check cluster connect done check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-restart-lqgc7 ns-vywof Restart flink-decauo jobmanager,taskmanager Succeed 2/2 Jun 19,2025 18:23 UTC+0800 check ops status done ops_status:flink-decauo-restart-lqgc7 ns-vywof Restart flink-decauo jobmanager,taskmanager Succeed 2/2 Jun 19,2025 18:23 UTC+0800 `kubectl patch -p '***"metadata":***"finalizers":[]***' --type=merge opsrequests flink-decauo-restart-lqgc7 --namespace ns-vywof ` opsrequest.apps.kubeblocks.io/flink-decauo-restart-lqgc7 patched `kbcli cluster delete-ops --name flink-decauo-restart-lqgc7 --force --auto-approve --namespace ns-vywof ` OpsRequest flink-decauo-restart-lqgc7 deleted cluster restart check cluster status before ops check cluster status done cluster_status:Running `kbcli cluster restart flink-decauo --auto-approve --force=true --components jobmanager --namespace ns-vywof ` OpsRequest flink-decauo-restart-vxpqs created successfully, you can view the progress: kbcli cluster describe-ops flink-decauo-restart-vxpqs -n ns-vywof check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-restart-vxpqs ns-vywof Restart flink-decauo jobmanager Creating -/- Jun 19,2025 18:24 UTC+0800 check cluster status `kbcli cluster list flink-decauo --show-labels --namespace ns-vywof ` NAME NAMESPACE CLUSTER-DEFINITION VERSION TERMINATION-POLICY STATUS CREATED-TIME LABELS flink-decauo ns-vywof flink flink-1.16 DoNotTerminate Running Jun 19,2025 18:13 UTC+0800 app.kubernetes.io/instance=flink-decauo,clusterdefinition.kubeblocks.io/name=flink,clusterversion.kubeblocks.io/name=flink-1.16 check cluster status done cluster_status:Running check pod status `kbcli cluster list-instances flink-decauo --namespace ns-vywof ` NAME NAMESPACE CLUSTER COMPONENT STATUS ROLE ACCESSMODE AZ CPU(REQUEST/LIMIT) MEMORY(REQUEST/LIMIT) STORAGE NODE CREATED-TIME flink-decauo-jobmanager-0 ns-vywof flink-decauo jobmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-3-103.us-west-2.compute.internal/172.31.3.103 Jun 19,2025 18:24 UTC+0800 flink-decauo-taskmanager-0 ns-vywof flink-decauo taskmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-10-42.us-west-2.compute.internal/172.31.10.42 Jun 19,2025 18:23 UTC+0800 check pod status done check cluster connect `echo "curl -s flink-decauo-jobmanager.ns-vywof.svc.cluster.local:8081" | kubectl exec -it flink-decauo-jobmanager-0 --namespace ns-vywof -- bash` connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... connect checking... check cluster connect done check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-restart-vxpqs ns-vywof Restart flink-decauo jobmanager Succeed 1/1 Jun 19,2025 18:24 UTC+0800 check ops status done ops_status:flink-decauo-restart-vxpqs ns-vywof Restart flink-decauo jobmanager Succeed 1/1 Jun 19,2025 18:24 UTC+0800 `kubectl patch -p '***"metadata":***"finalizers":[]***' --type=merge opsrequests flink-decauo-restart-vxpqs --namespace ns-vywof ` opsrequest.apps.kubeblocks.io/flink-decauo-restart-vxpqs patched `kbcli cluster delete-ops --name flink-decauo-restart-vxpqs --force --auto-approve --namespace ns-vywof ` OpsRequest flink-decauo-restart-vxpqs deleted check component taskmanager exists `kubectl get components -l app.kubernetes.io/instance=flink-decauo,apps.kubeblocks.io/component-name=taskmanager --namespace ns-vywof | (grep "taskmanager" || true )` cluster restart check cluster status before ops check cluster status done cluster_status:Running `kbcli cluster restart flink-decauo --auto-approve --force=true --components taskmanager --namespace ns-vywof ` OpsRequest flink-decauo-restart-kxdqq created successfully, you can view the progress: kbcli cluster describe-ops flink-decauo-restart-kxdqq -n ns-vywof check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-restart-kxdqq ns-vywof Restart flink-decauo taskmanager Pending -/- Jun 19,2025 18:25 UTC+0800 check cluster status `kbcli cluster list flink-decauo --show-labels --namespace ns-vywof ` NAME NAMESPACE CLUSTER-DEFINITION VERSION TERMINATION-POLICY STATUS CREATED-TIME LABELS flink-decauo ns-vywof flink flink-1.16 DoNotTerminate Running Jun 19,2025 18:13 UTC+0800 app.kubernetes.io/instance=flink-decauo,clusterdefinition.kubeblocks.io/name=flink,clusterversion.kubeblocks.io/name=flink-1.16 check cluster status done cluster_status:Running check pod status `kbcli cluster list-instances flink-decauo --namespace ns-vywof ` NAME NAMESPACE CLUSTER COMPONENT STATUS ROLE ACCESSMODE AZ CPU(REQUEST/LIMIT) MEMORY(REQUEST/LIMIT) STORAGE NODE CREATED-TIME flink-decauo-jobmanager-0 ns-vywof flink-decauo jobmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-3-103.us-west-2.compute.internal/172.31.3.103 Jun 19,2025 18:24 UTC+0800 flink-decauo-taskmanager-0 ns-vywof flink-decauo taskmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-10-42.us-west-2.compute.internal/172.31.10.42 Jun 19,2025 18:25 UTC+0800 check pod status done check cluster connect `echo "curl -s flink-decauo-jobmanager.ns-vywof.svc.cluster.local:8081" | kubectl exec -it flink-decauo-jobmanager-0 --namespace ns-vywof -- bash` check cluster connect done check ops status `kbcli cluster list-ops flink-decauo --status all --namespace ns-vywof ` NAME NAMESPACE TYPE CLUSTER COMPONENT STATUS PROGRESS CREATED-TIME flink-decauo-restart-kxdqq ns-vywof Restart flink-decauo taskmanager Succeed 1/1 Jun 19,2025 18:25 UTC+0800 check ops status done ops_status:flink-decauo-restart-kxdqq ns-vywof Restart flink-decauo taskmanager Succeed 1/1 Jun 19,2025 18:25 UTC+0800 `kubectl patch -p '***"metadata":***"finalizers":[]***' --type=merge opsrequests flink-decauo-restart-kxdqq --namespace ns-vywof ` opsrequest.apps.kubeblocks.io/flink-decauo-restart-kxdqq patched `kbcli cluster delete-ops --name flink-decauo-restart-kxdqq --force --auto-approve --namespace ns-vywof ` OpsRequest flink-decauo-restart-kxdqq deleted cluster update terminationPolicy WipeOut `kbcli cluster update flink-decauo --termination-policy=WipeOut --namespace ns-vywof ` cluster.apps.kubeblocks.io/flink-decauo updated check cluster status `kbcli cluster list flink-decauo --show-labels --namespace ns-vywof ` NAME NAMESPACE CLUSTER-DEFINITION VERSION TERMINATION-POLICY STATUS CREATED-TIME LABELS flink-decauo ns-vywof flink flink-1.16 WipeOut Running Jun 19,2025 18:13 UTC+0800 app.kubernetes.io/instance=flink-decauo,clusterdefinition.kubeblocks.io/name=flink,clusterversion.kubeblocks.io/name=flink-1.16 check cluster status done cluster_status:Running check pod status `kbcli cluster list-instances flink-decauo --namespace ns-vywof ` NAME NAMESPACE CLUSTER COMPONENT STATUS ROLE ACCESSMODE AZ CPU(REQUEST/LIMIT) MEMORY(REQUEST/LIMIT) STORAGE NODE CREATED-TIME flink-decauo-jobmanager-0 ns-vywof flink-decauo jobmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-3-103.us-west-2.compute.internal/172.31.3.103 Jun 19,2025 18:24 UTC+0800 flink-decauo-taskmanager-0 ns-vywof flink-decauo taskmanager Running us-west-2a 200m / 200m 1181116006400m / 1181116006400m ip-172-31-10-42.us-west-2.compute.internal/172.31.10.42 Jun 19,2025 18:25 UTC+0800 check pod status done check cluster connect `echo "curl -s flink-decauo-jobmanager.ns-vywof.svc.cluster.local:8081" | kubectl exec -it flink-decauo-jobmanager-0 --namespace ns-vywof -- bash` check cluster connect done cluster list-logs `kbcli cluster list-logs flink-decauo --namespace ns-vywof ` No log files found. You can enable the log feature with the kbcli command below. kbcli cluster update flink-decauo --enable-all-logs=true --namespace ns-vywof Error from server (NotFound): pods "flink-decauo-jobmanager-0" not found cluster logs `kbcli cluster logs flink-decauo --tail 30 --namespace ns-vywof ` 2025-06-19 10:25:06,871 INFO akka.remote.Remoting [] - Starting remoting 2025-06-19 10:25:07,173 INFO akka.remote.Remoting [] - Remoting started; listening on addresses :[akka.tcp://flink-metrics@flink-decauo-jobmanager:37967] 2025-06-19 10:25:07,378 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Actor system started at akka.tcp://flink-metrics@flink-decauo-jobmanager:37967 2025-06-19 10:25:07,576 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at akka://flink-metrics/user/rpc/MetricQueryService . 2025-06-19 10:25:07,877 INFO org.apache.flink.runtime.dispatcher.FileExecutionGraphInfoStore [] - Initializing FileExecutionGraphInfoStore: Storage directory /tmp/executionGraphStore-e571a09c-b24d-462d-b67f-0e6bee6be785, expiration time 3600000, maximum cache size 52428800 bytes. 2025-06-19 10:25:08,278 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Upload directory /tmp/flink-web-c7b91543-050e-40eb-b60d-0e5dadb2d44a/flink-web-upload does not exist. 2025-06-19 10:25:08,279 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Created directory /tmp/flink-web-c7b91543-050e-40eb-b60d-0e5dadb2d44a/flink-web-upload for file uploads. 2025-06-19 10:25:08,373 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Starting rest endpoint. 2025-06-19 10:25:13,577 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - Determined location of main cluster component log file: /opt/flink/log/flink--standalonesession-0-flink-decauo-jobmanager-0.log 2025-06-19 10:25:13,577 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - Determined location of main cluster component stdout file: /opt/flink/log/flink--standalonesession-0-flink-decauo-jobmanager-0.out 2025-06-19 10:25:16,070 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Rest endpoint listening at 0.0.0.0:8081 2025-06-19 10:25:16,072 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - http://0.0.0.0:8081 was granted leadership with leaderSessionID=00000000-0000-0000-0000-000000000000 2025-06-19 10:25:16,073 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Web frontend listening at http://0.0.0.0:8081. 2025-06-19 10:25:16,275 INFO org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner [] - DefaultDispatcherRunner was granted leadership with leader id 00000000-0000-0000-0000-000000000000. Creating new DispatcherLeaderProcess. 2025-06-19 10:25:16,281 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Start SessionDispatcherLeaderProcess. 2025-06-19 10:25:16,371 INFO org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - Starting resource manager service. 2025-06-19 10:25:16,373 INFO org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] - Resource manager service is granted leadership with session id 00000000-0000-0000-0000-000000000000. 2025-06-19 10:25:16,472 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Recover all persisted job graphs that are not finished, yet. 2025-06-19 10:25:16,572 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Successfully recovered 0 persisted job graphs. 2025-06-19 10:25:17,071 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/rpc/dispatcher_0 . 2025-06-19 10:25:17,274 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/rpc/resourcemanager_1 . 2025-06-19 10:25:17,871 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Starting the resource manager. WARNING: An illegal reflective access operation has occurred WARNING: Illegal reflective access by org.jboss.netty.util.internal.ByteBufferUtil (file:/tmp/flink-rpc-akka_4b55a9f2-2392-4081-92b3-a62b5a7d1d56.jar) to method java.nio.DirectByteBuffer.cleaner() WARNING: Please consider reporting this to the maintainers of org.jboss.netty.util.internal.ByteBufferUtil WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations WARNING: All illegal access operations will be denied in a future release 2025-06-19 10:25:24,075 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Registering TaskManager with ResourceID 172.31.3.153:39317-1ce115 (akka.tcp://flink@172.31.3.153:39317/user/rpc/taskmanager_0) at ResourceManager 2025-06-19 10:25:24,183 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Registering TaskManager with ResourceID 172.31.3.153:39317-1ce115 (akka.tcp://flink@172.31.3.153:39317/user/rpc/taskmanager_0) at ResourceManager 2025-06-19 10:25:27,791 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Closing TaskExecutor connection 172.31.3.153:39317-1ce115 because: The TaskExecutor is shutting down. delete cluster flink-decauo `kbcli cluster delete flink-decauo --auto-approve --namespace ns-vywof ` Cluster flink-decauo deleted pod_info:flink-decauo-jobmanager-0 1/1 Terminating 0 105s flink-decauo-taskmanager-0 1/1 Terminating 0 33s No resources found in ns-vywof namespace. delete cluster pod done No resources found in ns-vywof namespace. check cluster resource non-exist OK: pvc No resources found in ns-vywof namespace. delete cluster done No resources found in ns-vywof namespace. No resources found in ns-vywof namespace. No resources found in ns-vywof namespace. Flink Test Suite All Done! --------------------------------------Flink (Topology = Replicas 1) Test Result-------------------------------------- [PASSED]|[Create]|[ClusterDefinition=flink;ClusterVersion=flink-1.16;]|[Description=Create a cluster with the specified cluster definition flink and cluster version flink-1.16] [PASSED]|[Connect]|[ComponentName=jobmanager]|[Description=Connect to the cluster] [PASSED]|[Connect]|[Endpoints=true]|[Description=Connect to the cluster] [PASSED]|[VerticalScaling]|[ComponentName=taskmanager]|[Description=VerticalScaling the cluster specify component taskmanager] [PASSED]|[VerticalScaling]|[ComponentName=jobmanager]|[Description=VerticalScaling the cluster specify component jobmanager] [PASSED]|[Stop]|[-]|[Description=Stop the cluster] [WARNING]|[Operation]|[Succeed Or Failed Soon]|[Description=-] [PASSED]|[Start]|[-]|[Description=Start the cluster] [PASSED]|[HorizontalScaling Out]|[ComponentName=taskmanager]|[Description=HorizontalScaling Out the cluster specify component taskmanager] [PASSED]|[HorizontalScaling In]|[ComponentName=taskmanager]|[Description=HorizontalScaling In the cluster specify component taskmanager] [PASSED]|[Restart]|[-]|[Description=Restart the cluster] [PASSED]|[Restart]|[ComponentName=jobmanager]|[Description=Restart the cluster specify component jobmanager] [PASSED]|[Restart]|[ComponentName=taskmanager]|[Description=Restart the cluster specify component taskmanager] [PASSED]|[Update]|[TerminationPolicy=WipeOut]|[Description=Update the cluster TerminationPolicy WipeOut] [PASSED]|[Delete]|[-]|[Description=Delete the cluster] [END]