[jira] [Created] (FLINK-1998) Equality filter predicate not correctly evaluated by Table API

[Shang Yuanchun (Jira)]

Fabian Hueske created FLINK-1998:
------------------------------------

             Summary: Equality filter predicate not correctly evaluated by Table API
                 Key: FLINK-1998
                 URL: https://issues.apache.org/jira/browse/FLINK-1998
             Project: Flink
          Issue Type: Test
          Components: Table API
    Affects Versions: 0.9
            Reporter: Fabian Hueske


Equality filter predicates do not work on Tables that are created from Pojo data sets (couldn't reproduce it with a table data set).
Inequality predicates seem to work.

The following program will not produce a result. If the predicate is changed to {{"a > 100"}} it will return the row.

{code}
public static void main(String[] args) throws Exception {

        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
        env.setParallelism(1);
        TableEnvironment tEnv = new TableEnvironment();

        DataSet<Pojo> pojos = env.fromElements(new Pojo(200, 400));
        Table t = tEnv
                        .toTable(pojos)
                        .filter("a = 200");

        DataSet<Row> result = tEnv.toSet(t, Row.class);
        result.print();
        env.execute();
}

public static class Pojo {
        public int a;
        public int b;

        public Pojo() { }

        public Pojo(int a, int b) {
                this.a = a;
                this.b = b;
        }
}
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)