skills.rest
yangyongyongyong
yangyongyongyongCOMMUNITY
Explore all skills by this author →
GitHub

flink-k8s

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
One-click install
npx skills add https://github.com/yangyongyongyong/skills --skill flink-k8s
Or copy as Structured Prompt for Agent▼
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.

Related Skills

Explore More Software Engineering Skills→
razorpayrazorpay
31

flink-optimizer

Analyze Flink runtime metrics, stream DAGs, and YAML configurations to generate optimization recommendations.

Official
Advanced
CyapstayeCyapstaye
9

polymarket

Query Polymarket prediction market data via public REST APIs.

Community
Intermediate
partme-aipartme-ai
610

kubernetes

Guide Kubernetes pods, services, deployments, ingress, and cluster management.

Official
Intermediate
ivanshamaevivanshamaev
14

airflow-starrocks-cdc-orchestrator

Orchestrate Kafka/Debezium and Flink CDC pipelines into StarRocks via Airflow DAGs.

Community
Advanced