Greg Hogan created FLINK-3335: --------------------------------- Summary: DataSourceTask object reuse when disabled Key: FLINK-3335 URL: https://issues.apache.org/jira/browse/FLINK-3335 Project: Flink Issue Type: Bug Components: Distributed Runtime Affects Versions: 1.0.0 Reporter: Greg Hogan Assignee: Greg Hogan
>From {{DataSourceTask.invoke()}}: {code} if ((returned = format.nextRecord(serializer.createInstance())) != null) { output.collect(returned); } {code} The returned value ({{returned}}) must be copied rather than creating and passing in a new instance. The {{InputFormat}} interface only permits the given object to be used and does not require a new object to be returned otherwise. -- This message was sent by Atlassian JIRA (v6.3.4#6332)