You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/12/08 20:28:11 UTC

[jira] [Resolved] (FLINK-3148) Support configured serializers for shipping UDFs

     [ https://issues.apache.org/jira/browse/FLINK-3148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Nick Dimiduk resolved FLINK-3148.
---------------------------------
    Resolution: Duplicate

Closing duplicate.

> Support configured serializers for shipping UDFs
> ------------------------------------------------
>
>                 Key: FLINK-3148
>                 URL: https://issues.apache.org/jira/browse/FLINK-3148
>             Project: Flink
>          Issue Type: Improvement
>            Reporter: Nick Dimiduk
>
> Java 8 lambdas are very useful for expressing flow logic. However, their closures need to be serialized to nodes in the cluster. Current implementation only uses Java Serialization, which is limiting when integrating code from other projects. I propose reusing flink's existing serialization mechanisms (POJO magic, Kryo, extensible, &c) for serializing UDF instances as well.
> Discussion: http://mail-archives.apache.org/mod_mbox/flink-user/201512.mbox/%3CCANZa%3DGuchEr60r4bFWARtepQ37ZivSUQn6A1-o2eT66_M%3DFW%2BA%40mail.gmail.com%3E



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)