Alexis Sarda-Espinosa created FLINK-10408:
---------------------------------------------
Summary: Cannot use window information in Table functions
Key: FLINK-10408
URL:
https://issues.apache.org/jira/browse/FLINK-10408 Project: Flink
Issue Type: Bug
Components: Table API & SQL
Environment: Flink v1.5.3
Reporter: Alexis Sarda-Espinosa
Given the examples shown in [here|[
https://flink.apache.org/news/2017/03/29/table-sql-api-update.html],] I assume the following should work:
{code:java}
ExecutionEnvironment execEnv = ExecutionEnvironment.getExecutionEnvironment();
BatchTableEnvironment tableEnv = TableEnvironment.getTableEnvironment(execEnv);
DataSource<Tuple3<Timestamp, String, Double>> source = execEnv.fromElements(
new Tuple3<>(Timestamp.valueOf("2018-09-20 22:00:00"), "a", 1.3),
new Tuple3<>(Timestamp.valueOf("2018-09-20 22:01:00"), "a", 2.1),
new Tuple3<>(Timestamp.valueOf("2018-09-20 22:02:00"), "a", 3.0),
new Tuple3<>(Timestamp.valueOf("2018-09-20 22:00:00"), "b", 2.2),
new Tuple3<>(Timestamp.valueOf("2018-09-20 22:01:00"), "b", 1.8)
);
Table table = tableEnv.fromDataSet(source)
.window(Slide.over("2.minutes").every("1.minute").on("f0").as("w"))
.groupBy("f1, w")
.select("(f2 * (f0 - w.start).exp() / 1.hour).sum" +
" / ((f0 - w.start).exp() / 1.hour).sum");
tableEnv.toDataSet(table, Row.class).print();
{code}
However, I get the following exception:
{code:java}
org.apache.flink.table.api.ValidationException: Cannot resolve [w] given input [f0, f1, f2]
{code}
Maybe related to this issue?
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
Locked
