[
https://issues.apache.org/jira/browse/FLINK-1998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-1998:
---------------------------------------
Assignee: Aljoscha Krettek
> 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
> Assignee: Aljoscha Krettek
>
> 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)
