Vasia Kalavri created FLINK-3444:
------------------------------------
Summary: env.fromElements relies on the first input element for
determining the DataSet/DataStream type
Key: FLINK-3444
URL: https://issues.apache.org/jira/browse/FLINK-3444
Project: Flink
Issue Type: Bug
Components: DataSet API, DataStream API
Affects Versions: 0.10.0, 1.0.0
Reporter: Vasia Kalavri
The {{fromElements}} method of the {{ExecutionEnvironment}} and
{{StreamExecutionEnvironment}} determines the DataSet/DataStream type by
extracting the type of the first input element.
This is problematic if the first element is a subtype of another element in the
collection.
For example, the following
{code}
DataStream<Event> input = env.fromElements(new Event(1, "a"), new SubEvent(2,
"b"));
{code}
succeeds, while the following
{code}
DataStream<Event> input = env.fromElements(new SubEvent(1, "a"), new Event(2,
"b"));
{code}
fails with "java.lang.IllegalArgumentException: The elements in the collection
are not all subclasses of SubEvent".
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
