flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Vasia Kalavri (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3444) env.fromElements relies on the first input element for determining the DataSet/DataStream type
Date Thu, 18 Feb 2016 19:49:18 GMT
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)

Mime
View raw message