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)
