[PR] [flink] Support parallelismConfigurable [paimon]

["yunfengzhou-hub (via GitHub)" <gi...@apache.org>]

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-unsubscribe@paimon.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] [flink] Support parallelismConfigurable [paimon]

["JingsongLi (via GitHub)" <gi...@apache.org>]

JingsongLi merged PR #5076:
URL: https://github.com/apache/paimon/pull/5076


-- 
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-unsubscribe@paimon.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org