flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Fabian Hueske (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-1998) Equality filter predicate not correctly evaluated by Table API
Date Fri, 08 May 2015 12:53:00 GMT
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.

public static void main(String[] args) throws Exception {

	ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
	TableEnvironment tEnv = new TableEnvironment();

	DataSet<Pojo> pojos = env.fromElements(new Pojo(200, 400));
	Table t = tEnv
			.filter("a = 200");

	DataSet<Row> result = tEnv.toSet(t, Row.class);

public static class Pojo {
	public int a;
	public int b;

	public Pojo() { }

	public Pojo(int a, int b) {
		this.a = a;
		this.b = b;

This message was sent by Atlassian JIRA

View raw message