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 316f308 [FLINK-25288][tests][pulsar] Make pulsar e2e tests more robust
add fb710ea [hotfix][doc] Fix typos.
add d0859f6 [FLINK-25046][runtime] Convert unspecified edge to rescale
when using adaptive batch scheduler
No new revisions were added by this update.
Summary of changes:
.../flink/streaming/api/graph/StreamGraph.java | 6 +-
.../api/graph/StreamingJobGraphGenerator.java | 14 ++++-
.../ForwardForConsecutiveHashPartitioner.java | 3 +-
.../ForwardForUnspecifiedPartitioner.java | 71 ++++++++++++++++++++++
.../ForwardForConsecutiveHashPartitionerTest.java | 48 ++++-----------
...a => ForwardForUnspecifiedPartitionerTest.java} | 50 +++------------
.../partitioner/StreamPartitionerTestUtils.java | 59 ++++++++++++++++++
7 files changed, 171 insertions(+), 80 deletions(-)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/ForwardForUnspecifiedPartitioner.java
copy
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/partitioner/{ForwardForConsecutiveHashPartitionerTest.java
=> ForwardForUnspecifiedPartitionerTest.java} (52%)
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/partitioner/StreamPartitionerTestUtils.java
