RTC

You run an MCP server to manage Alibaba Cloud Realtime Compute for Apache Flink resources through a standardized interface. This enables you to create and manage Flink clusters and jobs, deploy applications, monitor status, handle savepoints, and work with workspaces, deployments, and catalogs in a cohesive workflow.

How to use

You connect to the RTC MCP Server from your MCP client using a predefined server configuration. This lets you start, stop, and manage Flink deployments and jobs, create savepoints, view deployment metrics, and query catalogs and tables via SQL statements.

How to install

Prerequisites you need before installing: JDK 17 or higher and Maven 3.6 or higher. You also require an Alibaba Cloud account with RTC access and your access key and secret.

mvn clean package

java -jar target/rtc-mcp-server-1.0-SNAPSHOT.jar

For development mode with stdio transport use:

java -Dtransport.mode=stdio -Dspring.main.web-application-type=none -jar target/rtc-mcp-server-1.0-SNAPSHOT.jar

Configuration and usage notes

To connect your MCP client, use the following example MCP client configuration. Replace the paths with your actual server location and provide your Alibaba Cloud credentials in the environment variables.

{
  "mcpServers": {
    "rtc-mcp-server": {
      "command": "java",
      "args": [
        "-Dtransport.mode=stdio",
        "-Dspring.main.web-application-type=none",
        "-Dspring.main.banner-mode=off",
        "-Dlogging.file.name=/path/to/rtc-mcp-server/mcpserver.log",
        "-jar",
        "/path/to/rtc-mcp-server/target/rtc-mcp-server-1.0-SNAPSHOT.jar"
      ],
      "env": {
        "ALIYUN_ACCESS_KEY_ID": "your-access-key-id",
        "ALIYUN_ACCESS_KEY_SECRET": "your-access-key-secret"
      },
      "disabled": false,
      "autoApprove": []
    }
  }
}

Available tools

start_job

Start a deployed Flink job within a deployment.

stop_job

Stop a running Flink job to halt processing.

list_jobs

List all jobs within a deployment with their current statuses.

delete_job

Delete a non-running job from the deployment.

get_job_diagnosis

Fetch diagnostic information to troubleshoot a failing or slow job.

create_deployment

Create a new Flink deployment to host jobs and applications.

get_deployment_metrics

Retrieve metrics for a given deployment to monitor health and performance.

create_savepoint

Create a savepoint for a running job to enable stateful recovery.

create_variable

Create a new variable for use across deployments and jobs.

update_variable

Update the value of an existing variable.

delete_variable

Delete a variable from the workspace.

list_variables

List all variables with pagination support.

create_workspace

Create a new workspace to organize workspaces and namespaces.

get_workspace_info

Get detailed information about a specific workspace.

list_workspaces

List all available workspaces in your account.

get_catalogs

Retrieve catalog information available to the MCP client.

get_deployment_databases

Get database information for a deployment context.

get_tables

List table information within a catalog or database.

execute_sql_statement

Execute SQL statements against a catalog/databases to query data.