-
Notifications
You must be signed in to change notification settings - Fork 1.3k
Description
Search before asking
- I searched in the issues and found nothing similar.
Paimon version
1.2.0
Compute Engine
flink1.20.2
Minimal reproduce step
建表:
CREATE TABLE IF NOT EXISTS paimon_hdfs.test_db.ods_table (
vin string comment '车辆识别码',
soc int commmecnt '电池soc',
dt string comment '日期分区,yyyy-MM-dd',
veh_type string comment '车辆类型'
)
PARTITIONED BY (dt,veh_type)
WITH (
'bucket-key' = 'vin',
'bucket' = '4'
);
查询:
批模式:
select *
from paimon_hdfs.test_db.ods_table /*+ OPTIONS('scan.infer-parallelism' = 'false','scan.parallelism' = '1','scan.split.target-size' = '1gb') */
where dt <= '2026-03-03' and dt >= '2026-03-02'
问题现象:
source端的并行度,始终是32,始终和bucket数量一致,即使设置了hints,也不生效。
如果上述表,分区修改成单层分区,只有一个dt分区,每个分区还是4个bucket,使用上述select语句,hints生效,source并行度 可以修改成功。
求助:
1、请问两层分区为什么并行度无法改变?
2、如何能让多层分区的并行度可以人为修改?
What doesn't meet your expectations?
/
Anything else?
No response
Are you willing to submit a PR?
- I'm willing to submit a PR!