ALTER-ROUTINE-LOAD
ALTER-ROUTINE-LOAD
Name
ALTER ROUTINE LOAD
Description
This syntax is used to modify an already created routine import job.
Only jobs in the PAUSED state can be modified.
grammar:
ALTER ROUTINE LOAD FOR [db.]job_name
[job_properties]
FROM data_source
[data_source_properties]
[db.]job_name
Specifies the job name to modify.
tbl_name
Specifies the name of the table to be imported.
job_properties
Specifies the job parameters that need to be modified. Currently, only the modification of the following parameters is supported:
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
partial_columns
max_filter_ratio
data_source
The type of data source. Currently supports:
KAFKA
data_source_properties
Relevant properties of the data source. Currently only supports:
kafka_partitions
kafka_offsets
kafka_broker_list
kafka_topic
- Custom properties, such as
property.group.id
Note:
kafka_partitions
andkafka_offsets
are used to modify the offset of the kafka partition to be consumed, only the currently consumed partition can be modified. Cannot add partition.
Example
Change
desired_concurrent_number
to 1ALTER ROUTINE LOAD FOR db1.label1
PROPERTIES
(
"desired_concurrent_number" = "1"
);Modify
desired_concurrent_number
to 10, modify the offset of the partition, and modify the 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