Node Action

Request

GET /rest/v2/manager/node/frontends

GET /rest/v2/manager/node/backends

GET /rest/v2/manager/node/brokers

GET /rest/v2/manager/node/configuration_name

GET /rest/v2/manager/node/node_list

POST /rest/v2/manager/node/configuration_info

POST /rest/v2/manager/node/set_config/fe

POST /rest/v2/manager/node/set_config/be

POST /rest/v2/manager/node/{action}/be

POST /rest/v2/manager/node/{action}/fe

POST /rest/v2/manager/node/{action}/broker (3.0.7+)

获取 fe, be, broker 节点信息

GET /rest/v2/manager/node/frontends

GET /rest/v2/manager/node/backends

GET /rest/v2/manager/node/brokers

Description

用于获取集群获取 fe, be, broker 节点信息。

Response

frontends:
{
    "msg": "success",
    "code": 0,
    "data": {
        "column_names": [
            "Name",
            "IP",
            "HostName",
            "EditLogPort",
            "HttpPort",
            "QueryPort",
            "RpcPort",
            "ArrowFlightSqlPort",
            "Role",
            "IsMaster",
            "ClusterId",
            "Join",
            "Alive",
            "ReplayedJournalId",
            "LastHeartbeat",
            "IsHelper",
            "ErrMsg",
            "Version"
        ],
        "rows": [
            [
                ...
            ]
        ]
    },
    "count": 0
}

backends:
{
    "msg": "success",
    "code": 0,
    "data": {
        "column_names": [
            "BackendId",
            "Cluster",
            "IP",
            "HostName",
            "HeartbeatPort",
            "BePort",
            "HttpPort",
            "BrpcPort",
            "LastStartTime",
            "LastHeartbeat",
            "Alive",
            "SystemDecommissioned",
            "ClusterDecommissioned",
            "TabletNum",
            "DataUsedCapacity",
            "AvailCapacity",
            "TotalCapacity",
            "UsedPct",
            "MaxDiskUsedPct",
            "ErrMsg",
            "Version",
            "Status"
        ],
        "rows": [
            [
                ...
            ]
        ]
    },
    "count": 0
}

brokers:
{
    "msg": "success",
    "code": 0,
    "data": {
        "column_names": [
            "Name",
            "IP",
            "HostName",
            "Port",
            "Alive",
            "LastStartTime",
            "LastUpdateTime",
            "ErrMsg"
        ],
        "rows": [
            [
                ...
            ]
        ]
    },
    "count": 0
}

获取节点配置信息

GET /rest/v2/manager/node/configuration_name

GET /rest/v2/manager/node/node_list

POST /rest/v2/manager/node/configuration_info

Description

configuration_name 用于获取节点配置项名称。
node_list 用于获取节点列表。
configuration_info 用于获取节点配置详细信息。

Query parameters

GET /rest/v2/manager/node/configuration_name

无

GET /rest/v2/manager/node/node_list

无

POST /rest/v2/manager/node/configuration_info

type

值为 fe 或 be，用于指定获取 fe 的配置信息或 be 的配置信息。

Request body

GET /rest/v2/manager/node/configuration_name

无

GET /rest/v2/manager/node/node_list

无

POST /rest/v2/manager/node/configuration_info

{
	"conf_name": [
		""
	],
	"node": [
		""
	]
}

若不带body，body中的参数都使用默认值。  

conf_name 用于指定返回哪些配置项的信息， 默认返回所有配置项信息；

node 用于指定返回哪些节点的配置项信息，默认为全部fe节点或be节点配置项信息。

Response

GET /rest/v2/manager/node/configuration_name

{
    "msg": "success",
    "code": 0,
    "data": {
        "backend":[
            ""
        ],
        "frontend":[
            ""
        ]
    },
    "count": 0
}

GET /rest/v2/manager/node/node_list

{
    "msg": "success",
    "code": 0,
    "data": {
        "backend": [
            ""
        ],
        "frontend": [
            ""
        ]
    },
    "count": 0
}

POST /rest/v2/manager/node/configuration_info?type=fe

{
    "msg": "success",
    "code": 0,
    "data": {
        "column_names": [
            "配置项",
            "节点",
            "节点类型",
            "配置值类型",
            "MasterOnly",
            "配置值",
            "可修改"
        ],
        "rows": [
            [
                ""
            ]
        ]
    },
    "count": 0
}

POST /rest/v2/manager/node/configuration_info?type=be

{
    "msg": "success",
    "code": 0,
    "data": {
        "column_names": [
            "配置项",
            "节点",
            "节点类型",
            "配置值类型",
            "配置值",
            "可修改"
        ],
        "rows": [
            [
                ""
            ]
        ]
    },
    "count": 0
}

Examples

获取 fe agent_task_resend_wait_time_ms 配置项信息：

POST /rest/v2/manager/node/configuration_info?type=fe

Body:

{
    "conf_name":[
        "agent_task_resend_wait_time_ms"
    ]
}

Response:

{
    "msg": "success",
    "code": 0,
    "data": {
        "column_names": [
            "配置项",
            "节点",
            "节点类型",
            "配置值类型",
            "MasterOnly",
            "配置值",
            "可修改"
        ],
        "rows": [
            [
                "agent_task_resend_wait_time_ms",
                "127.0.0.1:8030",
                "FE",
                "long",
                "true",
                "50000",
                "true"
            ]
        ]
    },
    "count": 0
}

修改配置值

POST /rest/v2/manager/node/set_config/fe

POST /rest/v2/manager/node/set_config/be

Description

用于修改 fe 或 be 节点配置值

Request body

{
	"config_name":{
		"node":[
			""
		],
		"value":"",
		"persist":
	}
}

config_name 为对应的配置项；
node 为关键字，表示要修改的节点列表;
value 为配置的值；
persist 为 true 表示永久修改， false 表示临时修改。永久修改重启后能生效，临时修改重启后失效。

Response

GET /rest/v2/manager/node/configuration_name

{
	"msg": "",
	"code": 0,
	"data": {
		"failed":[
			{
				"config_name":"name",
				"value"="",
				"node":"",
				"err_info":""
			}
		]
	},
	"count": 0
}

failed 表示修改失败的配置信息。

Examples

修改 fe 127.0.0.1:8030 节点中 agent_task_resend_wait_time_ms 和 alter_table_timeout_second 配置值：

POST /rest/v2/manager/node/set_config/fe

Body:

{
    "agent_task_resend_wait_time_ms":{
        "node":[
	    	"127.0.0.1:8030"
	    ],
	    "value":"10000",
	    "persist":"true"
    },
    "alter_table_timeout_second":{
        "node":[
	    	"127.0.0.1:8030"
	    ],
	    "value":"true",
	    "persist":"true"
    }
}

Response:

{
    "msg": "success",
    "code": 0,
    "data": {
        "failed": [
            {
                "config_name": "alter_table_timeout_second",
                "node": "10.81.85.89:8837",
                "err_info": "Unsupported configuration value type.",
                "value": "true"
            }
        ]
    },
    "count": 0
}

agent_task_resend_wait_time_ms 配置值修改成功，alter_table_timeout_second 修改失败。

操作 be 节点

POST /rest/v2/manager/node/{action}/be

Description

用于添加/删除/下线 be 节点

action：ADD/DROP/DECOMMISSION

Request body

{
    "hostPorts": ["127.0.0.1:9050"],
    "properties": {
        "tag.location": "test"
    }
}

hostPorts 需要操作的一组 be 节点地址 ip:heartbeat_port
properties 添加节点时传入的配置，目前只用于配置 tag, 不传使用默认 tag

Response

{
    "msg": "Error",
    "code": 1,
    "data": "errCode = 2, detailMessage = Same backend already exists[127.0.0.1:9050]",
    "count": 0
}

Examples

添加 be 节点

POST /rest/v2/manager/node/ADD/be

Request

{
    "hostPorts": ["127.0.0.1:9050"]
}

Response

{
    "msg": "success",
    "code": 0,
    "data": null,
    "count": 0
}

删除 be 节点

POST /rest/v2/manager/node/DROP/be

Request

{
    "hostPorts": ["127.0.0.1:9050"]
}

Response

{
    "msg": "success",
    "code": 0,
    "data": null,
    "count": 0
}

下线 be 节点

POST /rest/v2/manager/node/DECOMMISSION/be

Request

{
    "hostPorts": ["127.0.0.1:9050"]
}

Response

{
    "msg": "success",
    "code": 0,
    "data": null,
    "count": 0
}

操作 fe 节点

POST /rest/v2/manager/node/{action}/fe

Description

用于添加/删除 fe 节点

action：ADD/DROP

Request body

{
    "role": "FOLLOWER",
    "hostPort": "127.0.0.1:9030"
}

role FOLLOWER/OBSERVER
hostPort 需要操作的 fe 节点地址 ip:edit_log_port

Response

{
    "msg": "Error",
    "code": 1,
    "data": "errCode = 2, detailMessage = frontend already exists name: 127.0.0.1:9030_1670495889415, role: FOLLOWER, 127.0.0.1:9030",
    "count": 0
}

Examples

添加 FOLLOWER 节点

POST /rest/v2/manager/node/ADD/fe

Request

{
    "role": "FOLLOWER",
    "hostPort": "127.0.0.1:9030"
}

Response

{
    "msg": "success",
    "code": 0,
    "data": null,
    "count": 0
}

删除 FOLLOWER 节点

POST /rest/v2/manager/node/DROP/fe

Request

{
    "role": "FOLLOWER",
    "hostPort": "127.0.0.1:9030"
}

Response

{
    "msg": "success",
    "code": 0,
    "data": null,
    "count": 0
}

操作 broker 节点

POST /rest/v2/manager/node/{action}/broker

自 3.0.7 支持。

Description

用于添加/删除 broker 节点

action：ADD/DROP/DROP_ALL

Request body

{
    "brokerName": "your_broker_name",
    "hostPortList": "broker_ip:broker_port"
}

Response

{
    "msg": "Error",
    "code": 1,
    "data": "errCode = 2, detailMessage = xxxx",
    "count": 0
}

Examples

添加 BROKER 节点

POST /rest/v2/manager/node/ADD/broker

Request

{
    "brokerName": "hdfs_broker",
    "hostPortList": "127.0.0.1:8001"
}

Response

{
    "msg": "success",
    "code": 0,
    "data": null,
    "count": 0
}

删除 BROKER 节点

POST /rest/v2/manager/node/DROP/broker

Request

{
    "brokerName": "hdfs_broker",
    "hostPortList": "127.0.0.1:8001"
}

Response

{
    "msg": "success",
    "code": 0,
    "data": null,
    "count": 0
}

删除一组 BROKER 节点

POST /rest/v2/manager/node/DROP_ALL/broker

Request

{
    "brokerName": "hdfs_broker",
    "hostPortList": ""
}

Response

{
    "msg": "success",
    "code": 0,
    "data": null,
    "count": 0
}

Request​

获取 fe, be, broker 节点信息​

Description​

Response​

获取节点配置信息​

Description​

Query parameters​

Request body​

Response​

Examples​

修改配置值​

Description​

Request body​

Response​

Examples​

操作 be 节点​

Description​

Request body​

Response​

Examples​

操作 fe 节点​

Description​

Request body​

Response​

Examples​

操作 broker 节点​

Description​

Request body​

Response​

Examples​

Request

获取 fe, be, broker 节点信息

Description

Response

获取节点配置信息

Description

Query parameters

Request body

Response

Examples

修改配置值

Description

Request body

Response

Examples

操作 be 节点

Description

Request body

Response

Examples

操作 fe 节点

Description

Request body

Response

Examples

操作 broker 节点

Description

Request body

Response

Examples