Hi Flink Community, I'd like to share *flink-mcp*, an MCP (Model Context Protocol) server that connects Apache Flink with AI assistants and other MCP-compatible tools.
*What it does:* flink-mcp enables AI assistants to interact directly with your Flink clusters through the SQL Gateway REST API. It provides a clean interface for executing Flink SQL queries, managing sessions, and streaming results. *Key capabilities:* - Execute Flink SQL queries through AI assistants - Manage streaming and batch jobs conversationally - Stream results with pagination support - Session management and cluster monitoring - Built on Flink SQL Gateway v3 REST API *Quick setup:* Start your Flink cluster and SQL Gateway: > ./bin/start-cluster.sh > ./bin/sql-gateway.sh start -Dsql-gateway.endpoint.rest.address=localhost > # Verify: curl http://localhost:8083/v3/info For Claude Desktop, add to your MCP config: > { > "mcpServers": { > "flink-mcp": { > "command": "uvx", > "args": ["flink-mcp"], > "env": { > "SQL_GATEWAY_API_BASE_URL": "http://localhost:8083"; > } > } > } > } > *Use cases:* - AI-assisted Flink SQL development and debugging - Interactive cluster exploration and job monitoring - Automated pipeline management through conversational interfaces *Repository:* https://github.com/cledar/flink-mcp Questions and feedback welcome! Regards, -- Maciek Bryński
