ALTER ROUTINE LOAD

ALTER ROUTINE LOAD 用于修改处于 PAUSED 状态的 Routine Load 作业。您可以执行 PAUSE ROUTINE LOAD 来暂停 Routine Load 作业。

成功修改 Routine Load 作业后，您可以

• 使用 SHOW ROUTINE LOAD 检查对 Routine Load 作业所做的修改。
• 使用 RESUME ROUTINE LOAD 恢复 Routine Load 作业。

您只能以对 StarRocks 表具有 INSERT 权限的用户身份管理在 StarRocks 表上运行的 Routine Load 作业。如果您没有 INSERT 权限，请按照 GRANT 中提供的说明，将 INSERT 权限授予用于连接 StarRocks 集群的用户。

语法

ALTER ROUTINE LOAD FOR [<db_name>.]<job_name>
[load_properties]
[job_properties]
FROM data_source
[data_source_properties]

参数

• [<db_name>.]<job_name>

  • db_name: 可选。StarRocks 数据库的名称。
  • job_name: 必需。要修改的 Routine Load 作业的名称。

• 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：请注意，StarRocks 仅支持修改已消费的 Kafka 分区的偏移量，不支持添加新的 Kafka 分区。
    • property.*：数据源 Kafka 的自定义参数，例如 property.kafka_default_offsets。

示例

1. 以下示例将加载作业的属性 desired_concurrent_number 的值增加到 5，以提高加载任务的并行度。

   ALTER ROUTINE LOAD FOR example_tbl_ordertest
   PROPERTIES
   (
   "desired_concurrent_number" = "5"
   );

2. 以下示例同时修改加载作业的属性和数据源信息。

   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"
   );

3. 以下示例同时修改过滤条件和数据加载到的 StarRocks 分区。

   ALTER ROUTINE LOAD FOR example_tbl_ordertest
   WHERE pay_dt < 2023-06-31
   PARTITION (p202306);