问题详细描述
创建目标表：
CREATE TABLE example_db.example_tbl1 (
order_id bigint NOT NULL COMMENT “订单编号”,
pay_dt date NOT NULL COMMENT “支付日期”,
customer_name varchar(26) NULL COMMENT “顾客姓名”,
nationality varchar(26) NULL COMMENT “国籍”,
pricedouble NULL COMMENT “支付金额”
)
ENGINE=OLAP
DUPLICATE KEY (order_id,pay_dt)
DISTRIBUTED BY HASH(order_id);
创建routine load
CREATE ROUTINE LOAD example_db.example_tbl2_ordertest2 ON example_tbl2
COLUMNS(commodity_id, customer_name, country, pay_time, price, pay_dt=from_unixtime(pay_time, ‘%Y%m%d’))
PROPERTIES
(
“desired_concurrent_number” = “5”,
“format” = “json”,
“jsonpaths” = “[”$.commodity_id","$.customer_name","$.country","$.pay_time","$.price"]"
)
FROM KAFKA
(
“kafka_broker_list” = “ip:9092”,
“kafka_topic” = “ordertest2”,
“property.kafka_default_offsets” = “OFFSET_BEGINNING”
);
【StarRocks版本】docker部署最新版本
数据没有写入，查看routine load信息发现报错，相同设置，csv格式数据可以正常写入
- 查询报错：
ErrorReason{errCode = 2, msg=‘failed to send proxy request to TNetworkAddress(hostname:127.0.0.1, port:8060) err Ocurrs time out with specfied time 12 SECONDS’}