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)
