[FLINK-4385] Union on Timestamp fields does not work

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.2.0
• Component/s: Table SQL / API
• Assignee: Jark Wu
• Reporter: Timo Walther
• Created: 11/Aug/16 17:36
• Updated: 15/Aug/16 07:29
• Resolved: 15/Aug/16 07:29

Description

The following does not work:

public static class SDF {
	public Timestamp t = Timestamp.valueOf("1990-10-10 12:10:10");
}
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
DataSet<SDF> dataSet1 = env.fromElements(new SDF());
DataSet<SDF> dataSet2 = env.fromElements(new SDF());

BatchTableEnvironment tableEnv = TableEnvironment.getTableEnvironment(env);
tableEnv.registerDataSet( "table0", dataSet1 );
tableEnv.registerDataSet( "table1", dataSet2 );
Table table = tableEnv.sql( "select t from table0 union select t from table1" );
DataSet<Row> d = tableEnv.toDataSet(table, Row.class);
d.print();

Issue Links

• links to: GitHub Pull Request #2362