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

["Aljoscha Krettek (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-1998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Aljoscha Krettek closed FLINK-1998.
-----------------------------------
    Resolution: Fixed

Fixed in https://github.com/apache/flink/commit/84dcb7c20f5d67dbb5a931ab56e68594e491034b


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