flink-extended / flink-remote-shuffle

Remote Shuffle Service for Flink
Apache License 2.0
191 stars 56 forks source link

[FRS-13] Draft pr for implementing reduce partition. #45

Closed TanYuxin-tyx closed 2 years ago

TanYuxin-tyx commented 2 years ago

What is the purpose of the change

This is a draft PR for implementing reduce partition for #13

Brief changelog

(for example:)

Verifying this change

This change added tests.

TanYuxin-tyx commented 2 years ago

An old draft code for ReducePartition implementatioin. Close it.