1、查看load task

show routine Load;  

SHOW  ROUTINE LOAD\G;

2、暂停一个load Task

PAUSE  ROUTINE LOAD FOR [job_name];               


PAUSE ROUTINE LOAD FOR load_test_user_3;

3、删除一个 

STOP ROUTINE LOAD FOR load_test_user_4;

4、查看日志，一定要查看be.INFO 

I0430 14:24:36.568722  6899 data_consumer.h:88] kafka error: Local: Host resolution failure, event: uat-datacenter2:9092/100: Failed to resolve 'uat-datacenter2:9092': Name or service not known (after 514035102ms in state INIT)
I0430 14:24:36.568774  6899 data_consumer.h:88] kafka error: Local: Host resolution failure, event: uat-datacenter1:9092/98: Failed to resolve 'uat-datacenter1:9092': Name or service not known (after 514035102ms in state INIT)
I0430 14:24:36.579171  6899 data_consumer.h:88] kafka error: Local: Host resolution failure, event: uat-datacenter3:9092/99: Failed to resolve 'uat-datacenter3:9092': Name or service not known (after 514035112ms in state INIT)

表示不知道kafka地址

5、错误信息

ReasonOfStateChanged: ErrorReason{code=errCode = 4, msg='Job failed to fetch all current partition with error errCode = 2, detailMessage = Failed to get all partitions of kafka topic: doris_test. error: errCode = 2, detailMessage = failed to get kafka partition info: [failed to get partition meta: Local: Broker transport failure]'}

表示分区信息获取不到

6、查看routine 建立信息

help routine load

7、查看建表信息

help create  table

 

#############案例##################

1、创建一个用户表

CREATE TABLE user
(
id INT DEFAULT '10',
name VARCHAR(32) DEFAULT '',
age DECIMAL(10, 2) DEFAULT "10.5",
create_time datetime NULL COMMENT ""
)
ENGINE=olap
UNIQUE KEY(id)
DISTRIBUTED BY HASH(id) BUCKETS 10
PROPERTIES("replication_num" = "1");

2、创建一个routine load

create routine load load_test_user_1 on user
columns (id,name,age,create_time),
columns terminated by ","
PROPERTIES (
    "desired_concurrent_number"="1",  
    "max_error_number"="1000"
)
FROM KAFKA (
    "kafka_broker_list"= "uat-datacenter2:9092",
    "kafka_topic" = "doris_test"

);

3、查看表信息

select * from user