[
https://issues.apache.org/jira/browse/FLINK-4801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4801.
---------------------------------
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 1.2.0 with 6f09ecded9e22a5eaa548ebbddb9b28dad4207c2.
> Input type inference is faulty with custom Tuples and RichFunctions
> -------------------------------------------------------------------
>
> Key: FLINK-4801
> URL: https://issues.apache.org/jira/browse/FLINK-4801
> Project: Flink
> Issue Type: Bug
> Components: Type Serialization System
> Reporter: Timo Walther
> Assignee: Timo Walther
> Fix For: 1.2.0
>
>
> This issue has been discussed on the ML:
> http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Type-problem-in-RichFlatMapFunction-when-using-GenericArray-type-td13929.html
> This returns the wrong type:
> {code}
> public static class Foo<K> extends Tuple2<K[], K> {
> public Foo() {
> }
> public Foo(K[] value0, K value1) {
> super(value0, value1);
> }
> }
> DataSource<Foo<T>> fooDataSource = env.fromElements(foo);
> DataSet<Foo<T>> ds = fooDataSource.join(fooDataSource)
> .where(field).equalTo(field)
> .with(new RichFlatJoinFunction<Foo<T>, Foo<T>, Foo<T>>() {
> @Override
> public void join(Foo<T> first, Foo<T> second,
> Collector<Foo<T>> out) throws Exception {
> out.collect(first);
> }
> });
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
