yunfengzhou-hub opened a new pull request, #5076: URL: https://github.com/apache/paimon/pull/5076
### Purpose In Flink 1.17+, the parameter `parallelismConfigurable` is introduced to support specifying operator's initial parallelism while dynamically changing parallelism in some situations (like in AQE). This PR adds this parameter to Paimon Flink operators where parallelism does not affect correctness, and can be changed by Flink infra according to detailed needs. Related PR: #4975 <!-- What is the purpose of the change --> ### Tests Flink batch execution mode enables AQE by default, so existing batch tests like BatchFileStoreITCase can verify the correctness of these changes. ### API and Format This change does not affect API or storage format. ### Documentation This change does not introduce a new feature that needs documentation. -- 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: issues-unsubscr...@paimon.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
