该语法用于修改已经创建的例行导入作业。
只能修改处于 PAUSED 状态的作业。
语法:
-
指定要修改的作业名称。
-
指定需要导入的表的名称。
job_properties
指定需要修改的作业参数。目前仅支持如下参数的修改:
desired_concurrent_number
max_batch_interval
max_batch_rows
max_batch_size
json_root
strip_outer_array
strict_mode
timezone
num_as_string
data_source
数据源的类型。当前支持:
-
数据源的相关属性。目前仅支持:
kafka_partitions
kafka_offsets
kafka_broker_list
kafka_topic
- 自定义 property,如
property.group.id
注:
kafka_partitions
和kafka_offsets
用于修改待消费的 kafka partition 的offset,仅能修改当前已经消费的 partition。不能新增 partition。
将 修改为 1