database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity
Files
c3b010b277f09dfce2b0e751e6949ea0dddec00c
doris/docs/en/sql-reference/sql-statements/Data Manipulation/alter-routine-load.md
Mingyu Chen 748604ff4f [RoutineLoad] Support alter broker list and topic for kafka routine load (#6335) 
```
alter routine load for cmy2 from kafka("kafka_broker_list" = "ip2:9094", "kafka_topic" = "my_topic");
```

This is useful when the kafka broker list or topic has been changed.

Also modify `show create routine load`, support showing  "kafka_partitions" and "kafka_offsets".
2021-08-03 11:58:38 +08:00

2.7 KiB
Raw Blame History

title, language
title language
ALTER ROUTINE LOAD en

ALTER ROUTINE LOAD

description

This syntax is used to modify a routine import job that has been created.

Only jobs in the PAUSED state can be modified.

Syntax:

ALTER ROUTINE LOAD FOR [db.]job_name
[job_properties]
FROM data_source
[data_source_properties]

  1. [db.]job_name

    Specify the name of the job to be modified.

  2. job_properties

    Specify the job parameters that need to be modified. Currently only supports the modification of the following parameters:

    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

  3. data_source

    The type of data source. Currently supported:

    KAFKA

  4. data_source_properties

    The relevant attributes of the data source. Currently only supports:

    1. kafka_partitions
    2. kafka_offsets
    3. kafka_broker_list
    4. kafka_topic
    5. Custom property, such as property.group.id

    Notice:

    1. kafka_partitions and kafka_offsets are used to modify the offset of the kafka partition to be consumed, and can only modify the currently consumed partition. Cannot add partition.

example

  1. Modify desired_concurrent_number to 1

    ALTER ROUTINE LOAD FOR db1.label1
PROPERTIES
(
    "desired_concurrent_number" = "1"
);

  2. Modify desired_concurrent_number to 10, modify partition offset, and modify 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"
);

keyword

ALTER,ROUTINE,LOAD