You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "yankai zhang (JIRA)" <ji...@apache.org> on 2019/04/04 16:17:00 UTC
[jira] [Created] (FLINK-12113) User code passing to
fromCollection(Iterator, Class) not cleaned
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)