Adapt to Flink 1.16 - Githubissues

flink-extended / flink-remote-shuffle

Remote Shuffle Service for Flink

Apache License 2.0

191 stars 56 forks source link

Closed TanYuxin-tyx closed 1 year ago

TanYuxin-tyx commented 2 years ago

As Flink 1.16 is going to release, the remote shuffle project should also adapt to 1.16.

Adapt to Flink 1.16 which means adapting to some new changes in Flink 1.16, including adaptive execution and other API changes.

Test manually on a cluster.

TanYuxin-tyx commented 1 year ago

A new branch dev-fink-1.16 has been added to adapt to Flink 1.16.