flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Maximilian Michels (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable
Date Thu, 05 Nov 2015 17:53:27 GMT

    [ https://issues.apache.org/jira/browse/FLINK-2124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14992103#comment-14992103
] 

Maximilian Michels commented on FLINK-2124:
-------------------------------------------

Just looked into this. The problem is not exactly the FromElements InputFormat but the ClosureCleaner
which tries to serialize the objects using Java serialization. Since the pull request, the
fromElements actually supports the serialization framework of Flink but the ClojureCleaner
prevents that from working.

I'm afraid the only workaround until this is fixed is to make your class implement Serializable.

> FromElementsFunction is not really Serializable
> -----------------------------------------------
>
>                 Key: FLINK-2124
>                 URL: https://issues.apache.org/jira/browse/FLINK-2124
>             Project: Flink
>          Issue Type: Bug
>          Components: Streaming
>            Reporter: Aljoscha Krettek
>            Assignee: Johannes Reifferscheid
>             Fix For: 0.10
>
>
> The function stores an Iterable of T. T is not necessarily Serializable and and Iterable
is also not necessarily Serializable.



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

Mime
View raw message