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

["Fabian Hueske (JIRA)" <ji...@apache.org>]

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)