【详述】目的是数据按照每小时间隔进行汇聚物化,物化视图保留12个小时的分区数据。
预期的是物化视图创建后,按照当前时间持续获取最近一小时数据更新进去。
创建后的物化视图分区如下,有最近12小时的分区:
从物化视图刷新的任务来看,StarRocks是从最开始的分区开始刷新的
而结果是因为当前时间已经是11:00了,不在最开始分区的00:00中,所以刷新失败了
我的问题是:
1、是否有办法设置StarRocks物化视图的刷新从最近一个分区开始?
2、是否有办法在创建物化视图的SQL中使用函数获取每次刷新的分区时间段,动态获取对应时间段的数据,来匹配分区的时间?
创建异步物化视图如下:
CREATE MATERIALIZED VIEW mv_1
DISTRIBUTED BY HASH(id
)
REFRESH ASYNC START(‘2023-12-21 11:44:00’) EVERY(INTERVAL 1 MINUTE)
PARTITION BY hour_time
PROPERTIES (
“force_external_table_query_rewrite” = “TRUE”,
“partition_ttl_number” = “12”,
“partition_refresh_number” = “2”,
“auto_refresh_partitions_limit” = “1”
)
as
SELECT
date_trunc(“hour”, dt) as hour_time, max(… from table
where dt >= time_slice(current_time(), interval 1 hour) and dt < time_slice(current_time(), interval 15 minute)
group by hour_time
【StarRocks版本】3.1.2
【集群规模】1fe+3be