[jira] [Created] (FLINK-3444) env.fromElements relies on the first input element for determining the DataSet/DataStream type

[Shang Yuanchun (Jira)]

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)