ALTER-ROUTINE-LOAD
更新时间:2022-12-01
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
-
data_source
数据源的类型。当前支持:
KAFKA
-
data_source_properties
数据源的相关属性。目前仅支持:
kafka_partitions
kafka_offsets
- 自定义 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
典型实践
该命令可以用于修正消费的 offset,或者在 Kafka 数据格式变更后,修改列的映射、转化和过滤规则。