flink-extended / flink-remote-shuffle

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

[FRS-89] Fix incompatibility with the new version of Flink #90

Closed TanYuxin-tyx closed 1 year ago

TanYuxin-tyx commented 1 year ago

What is the purpose of the change

Fix incompatibility with the new version of Flink

This change will not affect the compatibility of RSS and lower versions of Flink. Because Flink ConnectionID has two construction methods, only one of which has changed. Previously, it was affected because the construction method used was changed. Now it is changed to the ConnectionID construction method that has not changed for several years, so it is compatible with the historical version of Flink.

Brief change log

Verifying this change

This change is a trivial code cleanup without any test coverage.