doris/ALTER-ROUTINE-LOAD.md at da1a0c96db65433e07a95ebaf29e9deee04e6213

Files

Mingyu Chen 74a482ca7f [fix] fix docs build bug (#9293 )

After this PR #9272, the `docs/build_help_zip.sh` will run failed.
This PR fix this issue.
But the help module still has some parse problem, I will fix it in next PR.

This CL mainly changes:
1. fix `docs/build_help_zip.sh` error
2. remove `sql-reference-v2` to `sql-reference`
3. modify build extension github action to run `docs/build_help_zip.sh`

2022-04-28 22:19:04 +08:00

2.7 KiB

Raw Blame History

title, language

title	language
ALTER-ROUTINE-LOAD	zh-CN

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

指定需要修改的作业参数。目前仅支持如下参数的修改：
1. desired_concurrent_number
2. max_error_number
3. max_batch_interval
4. max_batch_rows
5. max_batch_size
6. jsonpaths
7. json_root
8. strip_outer_array
9. strict_mode
10. timezone
11. num_as_string
12. fuzzy_parse
data_source

数据源的类型。当前支持：

KAFKA
data_source_properties

数据源的相关属性。目前仅支持：
1. kafka_partitions
2. kafka_offsets
3. kafka_broker_list
4. kafka_topic
5. 自定义 property，如 property.group.id
注：
1. kafka_partitions 和 kafka_offsets 用于修改待消费的 kafka partition 的offset，仅能修改当前已经消费的 partition。不能新增 partition。

Example

将 desired_concurrent_number 修改为 1

ALTER 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

2.7 KiB Raw Blame History