ALTER-ROUTINE-LOAD
Name
ALTER ROUTINE LOAD
Description
该语法用于修改已经创建的例行导入作业。
只能修改处于 PAUSED 状态的作业。
语法:
ALTER ROUTINE LOAD FOR [db.]job_name
[job_properties]
FROM data_source
[data_source_properties]
[db.]job_name
指定要修改的作业名称。
tbl_name
指定需要导入的表的名称。
job_properties
指定需要修改的作业参数。目前仅支持如下参数的修改:
desired_concurrent_number
max_error_number
max_batch_interval
max_batch_rows
max_batch_size
jsonpaths
json_root
strip_outer_array
strict_mode
timezone
num_as_string
fuzzy_parse
data_source
数据源的类型。当前支持:
KAFKA
data_source_properties
数据源的相关属性。目前仅支持:
kafka_partitions
kafka_offsets
kafka_broker_list
kafka_topic
- 自定义 property,如
property.group.id
注:
kafka_partitions
和kafka_offsets
用于修改待消费的 kafka partition 的offset,仅能修改当前已经消费的 partition。不能新增 partition。
Example
将
desired_concurrent_number
修改为 1ALTER ROUTINE LOAD FOR db1.label1
PROPERTIES
(
"desired_concurrent_number" = "1"
);
将
desired_concurrent_number
修改为 10,修改 partition 的offset,修改 group id。ALTER ROUTINE LOAD FOR db1.label1
PROPERTIES
(
"desired_concurrent_number" = "10"
)
FROM kafka
(
"kafka_partitions" = "0, 1, 2",
"kafka_offsets" = "100, 200, 100",
"property.group.id" = "new_group"
);
Keywords
ALTER, ROUTINE, LOAD