[flink] branch master updated (cf3beff586a -> 56e91700ca5)

[xt...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from cf3beff586a [FLINK-28876][python][format/orc] Support Orc format
     add be5893c582e [hotfix] Migrate RestartPipelinedRegionFailoverStrategyTest to Junit5 and AssertJ.
     add bfe64603242 [FLINK-28701] Split HYBRID result partition type to HYBRID_FULL and HYBRID_SELECTIVE.
     add 9df886e222e [FLINK-28701] RestartPipelinedRegionFailoverStrategy takes reConsumable into account when decide partition available.
     add 56e91700ca5 [FLINK-28701] Remove WIP prefix of ALL_EXCHANGE_HYBRID_FULL and ALL_EXCHANGE_HYBRID_SELECTIVE in BatchShuffleMode and expose them to documents.

No new revisions were added by this update.

Summary of changes:
 .../generated/execution_configuration.html         |  2 +-
 .../apache/flink/api/common/BatchShuffleMode.java  | 27 ++++++--
 .../flink/configuration/ExecutionOptions.java      | 11 ++-
 .../RestartPipelinedRegionFailoverStrategy.java    | 29 +++++++-
 .../network/partition/ResultPartitionFactory.java  |  9 ++-
 .../io/network/partition/ResultPartitionType.java  | 16 ++++-
 ...RestartPipelinedRegionFailoverStrategyTest.java | 81 +++++++++++++++++-----
 .../partition/ResultPartitionFactoryTest.java      | 26 +++++--
 .../partition/hybrid/HsResultPartitionTest.java    |  4 +-
 .../PipelinedRegionSchedulingStrategyTest.java     | 79 +++++++++++++++------
 .../api/graph/GlobalStreamExchangeMode.java        |  7 +-
 .../streaming/api/graph/StreamGraphGenerator.java  |  6 +-
 .../api/graph/StreamingJobGraphGenerator.java      | 15 ++--
 .../api/transformations/StreamExchangeMode.java    | 11 ++-
 .../StreamGraphGeneratorBatchExecutionTest.java    |  9 ++-
 .../api/graph/StreamingJobGraphGeneratorTest.java  | 76 +++++++++++++++++---
 16 files changed, 326 insertions(+), 82 deletions(-)