Yingjie Cao created FLINK-26347: ----------------------------------- Summary: Should use Flink system Classloader (AppClassloader) when deserializing RPC message Key: FLINK-26347 URL: https://issues.apache.org/jira/browse/FLINK-26347 Project: Flink Issue Type: Bug Affects Versions: 1.15.0 Reporter: Yingjie Cao Fix For: 1.15.0
FLINK-25742 removed the redundant serialization of RPC invocation at Flink side. However, by accident, which changes the class loading behavior. Before FLINK-25742, Flink system Classloader is used to load RPC message class, but after FLINK-25742, the RpcSystem Classloader (its parent Classloader is not Flink system Classloader) is used which can cause ClassNotFoundException. I encountered this exception when trying to run flink-remote-shuffle on the latest Flink 1.15-SNAPSHOT, the remote shuffle class (shuffle descriptor class) can not be found even when the corresponding jar file is in Flink lib/ directory. -- This message was sent by Atlassian Jira (v8.20.1#820001)