You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2019/01/29 13:08:00 UTC
[jira] [Resolved] (FLINK-11071) Dynamic proxy classes cannot be
resolved when deserializing job graph
[ https://issues.apache.org/jira/browse/FLINK-11071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dawid Wysakowicz resolved FLINK-11071.
--------------------------------------
Resolution: Fixed
Fix Version/s: 1.8.0
1.7.2
1.6.4
Fixed in:
master: 7eec6cdde32c94c13495515ed7335fc42be17fb5 fa84869864b6e5faa4abec1c359f55c4fe4b4ab9
1.7.2: d241a419ee5be486f1b563ac8d19b48897b75bbe 885869edb1ba46051af89450370569d62965ca3a
1.6.4: 4321bd3dd59523129f5ba2500711b5694780720a bdc29b98f10f6a2757b0718cc7916a5b71546944
> Dynamic proxy classes cannot be resolved when deserializing job graph
> ---------------------------------------------------------------------
>
> Key: FLINK-11071
> URL: https://issues.apache.org/jira/browse/FLINK-11071
> Project: Flink
> Issue Type: Bug
> Components: Core
> Affects Versions: 1.6.2, 1.7.0, 1.8.0
> Reporter: Oleg Zhukov
> Assignee: BoWang
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.6.4, 1.7.2, 1.8.0
>
> Attachments: SocketWindowWordCount.java
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> It turns impossible to use Java dynamic proxy objects in the job definition (for example, as a MapFunction implementation).
> During deserialization of the job graph, the default implementation of ObjectInputStream.resolveProxyClass(..) is used, which is not using the custom class loader (to look into the submitted jar) and therefore throws ClassNotFoundException.
> Looks like in order to address this, InstantiationUtil.ClassLoaderObjectInputStream needs to provide custom implementation of resolveProxyClass(..) method as well (in addition to resolveClass(..)).
> In order to reproduce the issue, run the attached SocketWindowWordCount Flink app. It's a slight variation of the canonical [SocketWindowWordCount
> example|https://ci.apache.org/projects/flink/flink-docs-master/tutorials/local_setup.html] with a dynamic proxy implementation of the flat map transformation.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)