3.1版本创建paimon的异步物化视图,按分区刷新不行

Viewed 2

在flink sql-client中创建表

CREATE TABLE `paimon`.`db_paimon`.`test4` (
  `id` INT NOT NULL,
  `name` STRING,
  dt TIMESTAMP(3),
  CONSTRAINT `PK_id` PRIMARY KEY (`id`,dt) NOT ENFORCED
) PARTITIONED BY (dt)
WITH (
  'snapshot.time-retained' = '100000d'
);

INSERT INTO test4 VALUES (1,'zs', CAST('2023-10-27 11:00:00' AS TIMESTAMP(3)));
INSERT INTO test4 VALUES (2,'zs2', CAST('2023-10-27 11:00:01' AS TIMESTAMP(3)));
INSERT INTO test4 VALUES (3,'zs3', CAST('2023-10-28 11:00:01' AS TIMESTAMP(3)));

在doris中创建异步物化视图

create materialized view test4_mv
  BUILD IMMEDIATE
  REFRESH AUTO ON SCHEDULE EVERY 1 minute
  PROPERTIES
(
    "replication_num" = "1"
)
as SELECT id,name,dt FROM paimon.db_paimon.test4 

查询视图task

SELECT * 
FROM tasks("type"="mv")

结果如下,显示还是全量刷新
image.png

0 Answers