[jira] [Created] (FLINK-4801) Input type inference is faulty with custom Tuples and RichFunctions

["Timo Walther (JIRA)" <ji...@apache.org>]

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)