Anton2025-11-06 opened a new issue, #7336:
URL: https://github.com/apache/paimon/issues/7336

   ### Search before asking
   
   - [x] I searched in the [issues](https://github.com/apache/paimon/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!


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to