search

flink-extended / flink-remote-shuffle

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

Incompatibility with the new version of Flink #89

Closed TanYuxin-tyx closed 1 year ago

TanYuxin-tyx commented 1 year ago

The compile process will be failed with the new version of Flink because the following issue.

[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time:  02:53 min
[INFO] Finished at: 2022-11-25T22:00:09+08:00
[INFO] ------------------------------------------------------------------------
[ERROR] Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.1:compile (default-compile) on project shuffle-plugin: Compilation failure
[ERROR] /home/github/flink-remote-shuffle/shuffle-plugin/src/main/java/com/alibaba/flink/shuffle/plugin/transfer/RemoteShuffleInputGate.java:[731,38] incompatible types: java.net.InetSocketAddress cannot be converted to org.apache.flink.runtime.taskmanager.TaskManagerLocation
[ERROR]
[ERROR] -> [Help 1]

The failed reason is that FLINK ConnectionID construction method is changed because of FLINK-29639.