You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by zh...@apache.org on 2022/02/11 01:20:59 UTC

[flink] branch master updated (9034b3c -> b4d5b66)

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

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


    from 9034b3c  [FLINK-26062][state/changelog] Replace poll() with remove() for PQ states
     add 90159f4  [FLINK-25996][runtime] Introduce job property isDynamicGraph to ExecutionConfig
     add b4d5b66  [FLINK-26004][runtime] Introduce ForwardForConsecutiveHashPartitioner

No new revisions were added by this update.

Summary of changes:
 .../apache/flink/api/common/ExecutionConfig.java   |  29 +++++-
 .../flink/api/common/ExecutionConfigTest.java      |  22 ++++
 .../api/graph/StreamingJobGraphGenerator.java      |  28 +++++
 .../ForwardForConsecutiveHashPartitioner.java      | 113 +++++++++++++++++++++
 .../ForwardForConsecutiveHashPartitionerTest.java  |  94 +++++++++++++++++
 5 files changed, 284 insertions(+), 2 deletions(-)
 create mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/ForwardForConsecutiveHashPartitioner.java
 create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/partitioner/ForwardForConsecutiveHashPartitionerTest.java