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
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