[ 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)