flink-k8s

Name: flink-k8s
Availability: InStock
Author: yangyongyongyong

Monitor and troubleshoot Flink jobs on Kubernetes via the Flink REST API.

1|Updated Apr 11, 2026

Search Tags:#monitoring #Kubernetes #REST API #diagnostics #Flink

Ready to run

npx skills add https://github.com/yangyongyongyong/skills --skill flink-k8s

💬 Prompt for ChatGPT / Claude Chat▼

Please help me install this Agent Skill.
Skill: flink-k8s
Source: https://github.com/yangyongyongyong/skills/tree/main/flink-k8s
Command: npx skills add https://github.com/yangyongyongyong/skills --skill flink-k8s

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill requires httpx, json, and includes scripts (resource) and references (resource) components.

What problem does it solve?

This Skill enables users to diagnose Apache Flink WebUI and Flink on Kubernetes jobs through the Flink REST API, offering a comprehensive set of tools for monitoring and troubleshooting.

Core Features & Use Cases

REST API Integration: Directly access and interact with the Flink REST API for detailed diagnostics.
Job Monitoring: Monitor job status, task chains, backpressure, checkpoints, and TaskManager and JobManager metrics.
Log Analysis: Analyze logs, thread dumps, and FlameGraphs for in-depth troubleshooting.
Use Case: When a Flink job is experiencing performance issues or errors, use this Skill to diagnose issues such as backpressure, skewed task chains, or checkpoint failures.

Quick Start

Use the flink-k8s skill to diagnose a Flink job by providing the WebUI URL or job ID.

Frequently Asked Questions about flink-k8s

High-intent search queries and answers about installing and using this skill.

FAQPage Schema

How do I diagnose Flink job backpressure and checkpoint failures on Kubernetes?▼

To diagnose Flink job backpressure and checkpoint failures on Kubernetes, use the Flink REST API to retrieve job status, task chains, and checkpoint metrics for troubleshooting performance issues.

What is the best way to monitor Flink TaskManager and JobManager metrics via REST API?▼

Monitoring Flink TaskManager and JobManager metrics via REST API involves querying the Flink WebUI endpoints to extract detailed performance data, thread dumps, and FlameGraphs for in-depth analysis.

Can I analyze Flink logs and thread dumps for jobs deployed on Kubernetes?▼

Yes, you can analyze Flink logs and thread dumps for Kubernetes deployments by accessing the Flink REST API, which provides direct integration for retrieving and examining job-specific log data.

Do I need Python libraries to interact with the Flink REST API for monitoring?▼

Yes, you need Python libraries like httpx and json to interact with the Flink REST API, as the diagnostic scripts rely on these dependencies to handle HTTP requests and parse API responses.

How to troubleshoot skewed task chains in a Flink application?▼

To troubleshoot skewed task chains in a Flink application, query the Flink REST API using the WebUI URL or job ID to fetch task chain details and identify performance bottlenecks.

What limitations exist when diagnosing Flink jobs through the REST API?▼

Diagnosing Flink jobs through the REST API requires an accessible Flink WebUI URL or job ID and depends on the API's available endpoints, meaning some deep system-level issues might need direct pod access.