[jira] [Created] (FLINK-12113) User code passing to fromCollection(Iterator, Class) not cleaned

[Shang Yuanchun (Jira)]

yankai zhang created FLINK-12113:
------------------------------------

             Summary: User code passing to fromCollection(Iterator, Class) not cleaned
                 Key: FLINK-12113
                 URL: https://issues.apache.org/jira/browse/FLINK-12113
             Project: Flink
          Issue Type: Bug
          Components: API / DataStream
    Affects Versions: 1.7.2
            Reporter: yankai zhang


 
{code:java}
interface IS<E> extends Iterator<E>, Serializable { }

StreamExecutionEnvironment
  .getExecutionEnvironment()
  .fromCollection(new IS<Object>() {
    @Override
    public boolean hasNext() {
      return false;
    }

    @Override
    public Object next() {
      return null;
    }
  }, Object.class);
{code}
Code piece above throws exception:
{code:java}
org.apache.flink.api.common.InvalidProgramException: The implementation of the SourceFunction is not serializable. The object probably contains or references non serializable fields.

  at org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:99)
....{code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)