ALTER ROUTINE LOAD

Description

该语法用于修改已经创建的例行导入作业。

只能修改处于 PAUSED 状态的作业。

1ALTER ROUTINE LOAD FOR [db.]job_name
2[job_properties]
3FROM data_source
4[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

• data_source

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

  KAFKA

• data_source_properties

  数据源的相关属性。目前仅支持：

  1. kafka_partitions
  2. kafka_offsets
  3. 自定义 property，如 property.group.id

  注：

  1. kafka_partitions 和 kafka_offsets 用于修改待消费的 kafka partition 的offset，仅能修改当前已经消费的 partition。不能新增 partition。

Example

1. 将 desired_concurrent_number 修改为 1

   SQL 复制

   1ALTER ROUTINE LOAD FOR db1.label1
   2PROPERTIES
   3(
   4    "desired_concurrent_number" = "1"
   5);

2. 将 desired_concurrent_number 修改为 10，修改 partition 的offset，修改 group id。

   SQL 复制

   1ALTER ROUTINE LOAD FOR db1.label1
   2PROPERTIES
   3(
   4    "desired_concurrent_number" = "10"
   5)
   6FROM kafka
   7(
   8    "kafka_partitions" = "0, 1, 2",
   9    "kafka_offsets" = "100, 200, 100",
   10    "property.group.id" = "new_group"
   11);

Keywords

1ALTER, ROUTINE, LOAD

典型实践

该命令可以用于修正消费的 offset，或者在 Kafka 数据格式变更后，修改列的映射、转化和过滤规则。