ALTER-ROUTINE-LOAD

          PALO

          ALTER-ROUTINE-LOAD

          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
          • data_source

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

            KAFKA

          • data_source_properties

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

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

            注:

            1. kafka_partitionskafka_offsets 用于修改待消费的 kafka partition 的offset,仅能修改当前已经消费的 partition。不能新增 partition。

          Example

          1. desired_concurrent_number 修改为 1

            ALTER ROUTINE LOAD FOR db1.label1
            PROPERTIES
            (
                "desired_concurrent_number" = "1"
            );
          2. 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

          最佳实践

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

          上一篇
          STOP-ROUTINE-LOAD
          下一篇
          CANCEL-LOAD