Timo Walther created FLINK-4801: ----------------------------------- Summary: 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: Table API & SQL Reporter: Timo Walther Assignee: Timo Walther
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)