SHOW ROUTINE LOAD
Description
This statement is used to display the running status of Routine Load jobs. You can view the status information of either a specific job or all jobs.
Syntax
SHOW [ALL] ROUTINE LOAD [FOR <jobName>];
Optional Parameters
1. [ALL]
Optional parameter. If specified, all jobs (including stopped or cancelled jobs) will be displayed. Otherwise, only currently running jobs will be shown.
2. [FOR <jobName>]
Optional parameter. Specifies the job name to view. If not specified, all jobs under the current database will be displayed.
Supports the following formats:
<job_name>: Shows the job with the specified name in the current database<db_name>.<job_name>: Shows the job with the specified name in the specified database
Return Results
| Field Name | Description |
|---|---|
| Id | Job ID |
| Name | Job name |
| CreateTime | Job creation time |
| PauseTime | Most recent job pause time |
| EndTime | Job end time |
| DbName | Corresponding database name |
| TableName | Corresponding table name (shows 'multi-table' for multiple tables) |
| IsMultiTable | Whether it's a multi-table job |
| State | Job running status |
| DataSourceType | Data source type: KAFKA |
| CurrentTaskNum | Current number of subtasks |
| JobProperties | Job configuration details |
| DataSourceProperties | Data source configuration details |
| CustomProperties | Custom configurations. Sensitive properties are masked as ******, see "Sensitive property masking" below |
| Statistic | Job running statistics |
| Progress | Job running progress |
| Lag | Job delay status |
| ReasonOfStateChanged | Reason for job state change |
| ErrorLogUrls | URLs to view filtered data that failed quality checks |
| OtherMsg | Other error messages |
| User | The user who created the job |
| Comment | The comment of the job |
| ComputeGroup | The compute group the job runs on |
| FirstErrorMsg | The first error message the job hit. Added in version 4.0.8 |
Sensitive property masking
Starting from version 4.0.8, sensitive properties of Kafka Routine Load jobs are shown as ****** in CustomProperties instead of in plain text. The output of SHOW CREATE ROUTINE LOAD is masked as well.
The following properties are recognized as sensitive and masked:
| Matching rule | Example |
|---|---|
Property named sasl.jaas.config | sasl.jaas.config |
Property named aws.access_key | aws.access_key |
Property named ssl.keystore.key or ssl.key.pem | ssl.keystore.key |
Ends with .password, .secret, .secret_key, or .secret.key | ssl.keystore.password, sasl.oauthbearer.client.secret |
Ends with .session_key or .session.token | aws.session.token |
Ends with .private.key, .private_key, or .passphrase, or contains .private.key. | sasl.oauthbearer.assertion.private.key.pem |
Masking only affects how the values are displayed; the property values the job actually uses are unchanged. To change these properties, set them again with ALTER ROUTINE LOAD — the original values cannot be read back from the SHOW result.
FirstErrorMsg versus OtherMsg
FirstErrorMsg: the first error the job hit while running, useful for finding the root cause. After a job has run for a long time, later errors are often knock-on effects of the first one.OtherMsg: the most recent other error message, overwritten by subsequent errors.
These values can also be queried from information_schema.routine_load_job. Starting from version 4.0.8, that table is served by the master FE, so FIRST_ERROR_MSG and ERROR_LOG_URLS are no longer empty when the query lands on a non-master FE.
Access Control Requirements
Users executing this SQL command must have at least the following permission:
| Privilege | Object | Notes |
|---|---|---|
| LOAD_PRIV | Table | SHOW ROUTINE LOAD requires LOAD permission on the table |
Notes
-
State descriptions:
- NEED_SCHEDULE: Job is waiting to be scheduled
- RUNNING: Job is running
- PAUSED: Job is paused
- STOPPED: Job has ended
- CANCELLED: Job has been cancelled
-
Progress description:
- For Kafka data source, shows the consumed offset for each partition
- For example, {"0":"2"} means the consumption progress of Kafka partition 0 is 2
-
Lag description:
- For Kafka data source, shows the consumption delay for each partition
- For example, {"0":10} means the consumption lag of Kafka partition 0 is 10
Examples
-
Show all routine load jobs (including stopped or cancelled ones) named test1
SHOW ALL ROUTINE LOAD FOR test1; -
Show currently running routine load jobs named test1
SHOW ROUTINE LOAD FOR test1; -
Show all routine load jobs (including stopped or cancelled ones) in example_db. Results can be one or multiple rows.
use example_db;
SHOW ALL ROUTINE LOAD; -
Show all currently running routine load jobs in example_db
use example_db;
SHOW ROUTINE LOAD; -
Show currently running routine load job named test1 in example_db
SHOW ROUTINE LOAD FOR example_db.test1; -
Show all routine load jobs (including stopped or cancelled ones) named test1 in example_db. Results can be one or multiple rows.
SHOW ALL ROUTINE LOAD FOR example_db.test1;