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

Nick Dimiduk commented on FLINK-2124:
-------------------------------------

I'm also confused. Further debugging, and I tried out [~rmetzger]'s advice of 
replacing fromElements with an anonymous instance of ParallelSourceFunction. 
I'm still getting the same stack out of {{ClosureCleaner}} saying my object is 
not serializable. Indeed, I do not implement {{Serializable}} for this object. 
My understanding was that Flink handled conformant POJOs automatically. Is this 
not the case with 0.9.1?

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

Reply via email to