$ loading_
通过 SQL Gateway 连接 Flink 集群,执行查询、管理会话并控制作业。
复制安装指令,让 AI 自动完成配置 · 推荐新手
"flink-mcp" 暂无可直接复制的安装信息,请查看页面文档或源码仓库。
连接到指定的 Flink SQL Gateway 会话,执行这条 SQL:SELECT user_id, COUNT(*) AS cnt FROM events GROUP BY user_id LIMIT 10; 并返回结果。
返回查询结果表,包含字段和前几行数据。
为测试环境创建一个新的 Flink 会话,设置并行度为 4,列出当前会话参数,然后保持会话可用于后续 SQL 执行。
返回新会话标识、配置详情以及可继续使用的会话状态。
列出当前 Flink 集群中的运行中作业,找到名称为 streaming_orders 的作业,返回其状态;如果正在运行,则安全停止它。
返回作业列表、目标作业状态,以及停止操作的执行结果。
通过 MCP 连接 StarRocks,帮助查询分析数据并支持数据库开发集成。