为了更快的定位您的问题,请提供以下信息,谢谢
【详述】Flink CDC同步数据到Starrocks 想要依靠Starrocks做异步物化视图 创建异步物化视图报错
【背景】Flink CDC同步数据到Starrocks 想要依靠Starrocks做异步物化视图 实现准实时数仓
【业务影响】
【是否存算分离】
【StarRocks版本】例如:3.1.14
【集群规模】例如:3fe(1 follower+2observer)+5be(fe与be混部)
【机器信息】CPU虚拟核/内存/网卡,例如:48C/64G/万兆
【联系方式】15757878147
【附件】
CREATE MATERIALIZED VIEW sales_data_view(mall_paid_time,store_id,quantity,sale_amt)
REFRESH ASYNC START(mall_paid_time) EVERY (interval 1 hour)
DISTRIBUTED BY HASH(store_id
)
AS
SELECT
sos.mall_paid_time,
so.store_id,
sod.quantity AS sale_qty,
CASE
WHEN so.store_id = 135 THEN CAST(sod.distribution_amount AS DOUBLE)
ELSE CAST(sod.Settlement_amount AS DOUBLE)
END AS sale_amt
FROM
ods_oms_sales_order so
JOIN ods_oms_sales_order_sub sos ON so.sales_order_id = sos.sales_order_id
JOIN ods_oms_sales_order_detail sod ON so.sales_order_id = sod.sales_order_id
WHERE
sod.sales_order_detail_type = 2;
[S1009] Statement.executeQuery() cannot issue statements that do not produce result sets.