ALTER PIPE
修改 Pipe 的执行状态或配置属性。
暂停和启动 Pipe
控制 Pipe 的执行状态：
-- 暂停 Pipe
ALTER PIPE pipe_name SET PIPE_EXECUTION_PAUSED = true;
-- 启动 Pipe
ALTER PIPE pipe_name SET PIPE_EXECUTION_PAUSED = false;
修改 Pipe 属性
修改 Pipe 的配置属性。每次只能修改一个属性，如需修改多个属性，需多次执行
ALTER
ALTER
命令。
ALTER PIPE pipe_name SET
[VIRTUAL_CLUSTER = 'virtual_cluster_name']
| [BATCH_INTERVAL_IN_SECONDS = '']
| [BATCH_SIZE_PER_KAFKA_PARTITION = '']
| [MAX_SKIP_BATCH_COUNT_ON_ERROR = '']
| [COPY_JOB_HINT = ''];
示例：
-- 修改计算集群
ALTER PIPE pipe_name SET VIRTUAL_CLUSTER = 'default';
-- 设置 COPY_JOB_HINT
ALTER PIPE pipe_name SET COPY_JOB_HINT = '{"cz.mapper.kafka.message.size": "2000000"}';
相关文档
