flink-optimizer
OfficialOptimize Flink jobs with runtime insights
Authorrazorpay
Version1.0.0
Installs0
System Documentation
What problem does it solve?
Flink job optimization by evaluating runtime metrics, stream DAGs, and YAML configurations to identify bottlenecks and misconfigurations that degrade throughput and reliability.
Core Features & Use Cases
- Analyze runtime metrics from Flink REST API to detect backpressure, skew, and parallelism issues.
- Inspect YAML jobspec for wiring, parallelism, and checkpoint configuration to validate DAG correctness.
- Generate actionable recommendations with exact file paths and configuration changes to fix issues in production clusters.
Quick Start
Run the Flink optimizer against a live cluster and a jobspec YAML to receive an optimization report with prioritized fixes.
Dependency Matrix
Required Modules
requestspyyaml
Components
scripts
💻 Claude Code Installation
Recommended: Let Claude install automatically. Simply copy and paste the text below to Claude Code.
Please help me install this Skill: Name: flink-optimizer Download link: https://github.com/razorpay/trino-gateway/archive/main.zip#flink-optimizer Please download this .zip file, extract it, and install it in the .claude/skills/ directory.
Agent Skills Search Helper
Install a tiny helper to your Agent, search and equip skill from 471,000+ vetted skills library on demand.