Generate executable Apache Flink SQL from natural language and a schema, then run it on real Flink with sample data to return verified SQL and actual output or errors.
Apache 2.0
615,361 tools. Updated 2026-09-27 04:12
"Apache Flink" matching MCP tools:
- Identify latency bottlenecks in CDC pipeline by analyzing per-segment delays (source to Kafka, Kafka to Flink, Flink to ClickHouse) with percentile metrics and freshness. Filter by market and time window.MIT
- Monitor consumer group lag and diagnose operational issues, detecting Flink crashes, down consumers, or uneven lag distribution.MIT
- Create a deployable Flink job that streams query results into a Kafka topic, with SELECT logic verified against sample data first.Apache 2.0
- Registers a Kafka topic as a queryable table in the Flink catalog using DDL, enabling real-time SQL queries on streaming data.Apache 2.0
- Renders ECharts options server-side to produce SVG, PNG, or self-contained HTML, enabling chart generation without a browser.Apache 2.0
Matching MCP Servers
- AlicenseNot gradedqualityCmaintenanceEnables interaction with Apache Flink clusters via the SQL Gateway, allowing query execution, session management, and job control through MCP tools.8Apache 2.0
- AlicenseNot gradedqualityDmaintenanceEnables AI-controlled management of Apache Beam data pipelines across different runners (Flink, Spark, Dataflow, Direct) via the Model Context Protocol.4MIT
Matching MCP Connectors
SaaS intelligence for AI agents. 5 unified tools cover 1,000+ services with 91-96% token savings.
Buy and manage RU PBN and international iGaming SEO links with protected Tier1.shop checkout.
- Lists all Apache Airflow DAGs with metadata including status, schedule, tags, and owners for workflow discovery and monitoring.Apache 2.0
- List installed Apache Airflow provider packages with their versions, descriptions, and included operators, hooks, and sensors. Responds to queries about provider availability and integration details.Apache 2.0
- Discover every schema visible on the Apache Drill cluster to simplify data source inspection.Apache 2.0
- Retrieve the Python source code of an Apache Airflow DAG by providing its DAG ID. Returns the DAG file content and file token for inspection and debugging.Apache 2.0
- List storage plugin configurations with secrets redacted to review data source settings in Apache Drill.Apache 2.0
- Lists all projects in Apache DolphinScheduler, providing their IDs, codes, names, and descriptions.Apache 2.0
- Retrieve comprehensive details for a specific Apache Airflow DAG, including schedule, pause status, owners, tags, and run configuration.Apache 2.0
- Monitor Apache Drill cluster health by retrieving Drillbit membership and overall cluster status.Apache 2.0
- Retrieve and manage a sorted, filtered, and paginated list of Flink SQL statements using REST API, enabling precise control over statement queries and data.MIT
- Apache 2.0
- Submit Flink SQL statements to process data streams in Confluent Cloud. Define statements with unique names, catalog, and database details for efficient execution within specified environments and compute pools.MIT
- Retrieve and analyze Flink statements and their results by querying the Flink REST API. Specify the statement name, organization, and environment to access real-time data streams or sampled results.MIT
- Remove specific Flink statements by sending requests to the Flink REST API, using organization, environment, and statement identifiers.MIT
- Build, parse, or analyze Content-Security-Policy headers with severity-ranked warnings. Assemble directives or audit existing policies for misconfigurations.MIT
- Generate best-practice HTTP security headers with configurable presets (recommended, strict, report-only) and output for nginx, Apache, Caddy, Cloudflare, and more. No scan needed; perfect for new or unscanned sites.MIT