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
524,441 tools. Updated 2026-09-06 15:49
"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
- Generate openCypher CREATE/MERGE statements to project a relational schema into an Apache AGE property graph, converting rows to vertices and foreign keys to edges, without executing them.MIT
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.
Pay-per-call Open Graph/link preview metadata for AI agents. $0.01 USDC per call, no signup.
- 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
- Check for existing Apache AGE property graphs in PostgreSQL. Get the graph name and OID for each to support graph queries and operations.MIT
- 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