You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Timo Walther (JIRA)" <ji...@apache.org> on 2017/12/13 15:53:02 UTC
[jira] [Created] (FLINK-8255) Key expressions on named rows types
do not work
Timo Walther created FLINK-8255:
-----------------------------------
Summary: Key expressions on named rows types do not work
Key: FLINK-8255
URL: https://issues.apache.org/jira/browse/FLINK-8255
Project: Flink
Issue Type: Bug
Components: DataSet API, DataStream API
Reporter: Timo Walther
The following program fails with a {{ClassCastException}}. It seems that key expressions and rows are not tested well. We should add more tests for them.
{code}
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
TypeInformation[] types = new TypeInformation[] {Types.INT, Types.INT};
String[] fieldNames = new String[]{"id", "value"};
RowTypeInfo rowTypeInfo = new RowTypeInfo(types, fieldNames);
env.fromCollection(Collections.singleton(new Row(2)), rowTypeInfo)
.keyBy("id").sum("value").print();
env.execute("Streaming WordCount");
{code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)