Keuntae Park created TAJO-1287:
----------------------------------
Summary: Duplicated Sort spec should be supported
Key: TAJO-1287
URL: https://issues.apache.org/jira/browse/TAJO-1287
Project: Tajo
Issue Type: Sub-task
Reporter: Keuntae Park
Priority: Minor
Following test code does not pass:
{code}
public final void testMultipleWindow() throws Exception {
KeyValueSet tableOptions = new KeyValueSet();
tableOptions.set(StorageConstants.TEXT_DELIMITER,
StorageConstants.DEFAULT_FIELD_DELIMITER);
tableOptions.set(StorageConstants.TEXT_NULL, "\\\\N");
Schema schema = new Schema();
schema.addColumn("id", TajoDataTypes.Type.INT4);
schema.addColumn("time", TajoDataTypes.Type.TIME);
schema.addColumn("name", TajoDataTypes.Type.TEXT);
String[] data = new String[]{ "1|12:11:12|abc", "2|10:11:13|def",
"2|05:42:41|ghi" };
TajoTestingCluster.createTable("multiwindow", schema, tableOptions, data,
1);
try {
ResultSet res = executeString(
"select id, last_value(time) over ( partition by id order by time )
as time_last, last_value(name) over ( partition by id order by time ) as
name_last from multiwindow");
String ascExpected = "id,time_last, name_last\n" +
"-------------------------------\n" +
"1,12:11:12,abc\n" +
"2,10:11:13,def\n" +
"2,10:11:13,def\n";
assertEquals(ascExpected, resultSetToString(res));
res.close();
} finally {
executeString("DROP TABLE multiwindow PURGE");
}
}
{code}
because the same order by key(in this case, 'time') induces Exception:
"org.apache.tajo.catalog.exception.AlreadyExistsFieldException: Already Exists
Field: default.multiwindow.time"
It looks like there is trivial bug when inserting additionalSortKeyColumns in
WindowAggExec.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)