[
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)
