ALTER ROUTINE LOAD
功能
该语法用于修改 Routine Load 导入作业。注意，只能修改处于 PAUSED 状态的作业。您可以通过 PAUSE ROUTINE LOAD 暂停 Routine Load 导入作业。
修改成功后，您可以：
- 通过 SHOW ROUTINE LOAD 检查修改后的作业详情。
- 通过 RESUME ROUTINE LOAD 重启该导入作业。
Routine Load 操作需要目标表的 INSERT 权限。如果您的用户账号没有 INSERT 权限，请参考 GRANT 给用户赋权。
语法
ALTER ROUTINE LOAD FOR [db_name.]<job_name>
[load_properties]
[job_properties]
FROM data_source
[data_source_properties]
参数说明
-
[<db_name>.]<job_name>指定要修改的作业名称。
-
load_properties待导入的源数据信息。语法如下：
[COLUMNS TERMINATED BY '<column_separator>'],
[ROWS TERMINATED BY '<row_separator>'],
[COLUMNS ([<column_name> [, ...] ] [, column_assignment [, ...] ] )],
[WHERE <expr>],
[PARTITION ([ <partition_name> [, ...] ])]
[TEMPORARY PARTITION (<temporary_partition1_name>[,<temporary_partition2_name>,...])]详细的参数介绍，请参见 CREATE ROUTINE LOAD。
-
job_properties导入作业的属性。语法如下：
PROPERTIES ("<key1>" = "<value1>"[, "<key2>" = "<value2>" ...])目前仅支持修改如下属性：
-
desired_concurrent_number -
max_error_number -
max_batch_interval -
max_batch_rows -
max_batch_size -
jsonpaths -
json_root -
strip_outer_array -
strict_mode -
timezone
详细的属性介绍，请参见 CREATE ROUTINE LOAD。
-
-
data_source和data_source_properties-
data_source必填，指定数据源，目前仅支持取值为
KAFKA。 -
data_source_properties数据源的相关属性。目前支持修改：
kafka_partitions和kafka_offsets：需要注意的是，仅支持修改当前已经消费的 Kafka partition 的 offset，不支持新增 Kafka partition。property.*： 自定义的数据源 Kafka 相关参数，例如property.kafka_default_offsets。
-
示例
-
将导入作业的属性
desired_concurrent_number调大至5，以提高导入任务的并行度。任务的并行度的详细说明，参见如何提高导入性能。ALTER ROUTINE LOAD FOR example_tbl_ordertest
PROPERTIES
(
"desired_concurrent_number" = "5"
); -
同时修改导入作业的属性和数据源信息。
ALTER ROUTINE LOAD FOR example_tbl_ordertest
PROPERTIES
(
"desired_concurrent_number" = "5"
)
FROM KAFKA
(
"kafka_partitions" = "0, 1, 2",
"kafka_offsets" = "100, 200, 100",
"property.group.id" = "new_group"
); -
同时修改过滤条件和导入的目标 StarRocks 分区。
ALTER ROUTINE LOAD FOR example_tbl_ordertest
WHERE pay_dt < 2023-06-31
PARTITION (p202306);