Re: Adaptive Batch Configuration Does Not Work

2022-03-01 Thread Lijie Wang
Thanks for feedback! Can you post the jobmanager log? This may be because the source parallelism has been set in some way (Kind of source can infer parallelism according to the catalog). Best, Lijie Edwin 于2022年3月1日周二 19:30写道: > Hi all, > > I was trying to run flink-tpcds tests on flink v1.15-s

Adaptive Batch Configuration Does Not Work

2022-03-01 Thread Edwin
Hi all, I was trying to run flink-tpcds tests on flink v1.15-snapshot, and I added "jobmanager.adaptive-batch-scheduler.default-source-parallelism: 8" along with some other configurations to the conf yaml file to enable adaptive job scheduler. But it turned out the source parallelism kept unch