Hi all, When I execute the code :
Table tupled3DsTable = tableEnv.fromDataStream(tuple3ds, Schema.newBuilder() .column("f0","TIMESTAMP_LTZ(3)") // Only TIMESTAMP_LTZ(0) to TIMESTAMP_LTZ(3) allowed .column("f1","STRING") .column("f2","STRING") .watermark("f0", "SOURCE_WATERMARK()") .build()).as("handlingTime", "transactionId", "originalEvent"); tupled3DsTable.printSchema(); Table t = tupled3DsTable .window(Session.withGap(lit(5).minutes()).on($("handlingTime")).as("w")) .select($("handlingTime"), $("transactionId"), $("originalEvent"), $("handlingTime").sum().over($("w"))); I get: error: cannot find symbol .select($("handlingTime"), $("transactionId"), $("originalEvent"), $("handlingTime").sum().over($("w"))); ^ symbol: method select(org.apache.flink.table.api.ApiExpression,org.apache.flink.table.api.ApiExpression,org.apache.flink.table.api.ApiExpression,org.apache.flink.table.api.ApiExpression) location: interface org.apache.flink.table.api.GroupWindowedTable The printSchema gives: ( `handlingTime` TIMESTAMP_LTZ(3) *ROWTIME*, `transactionId` STRING, `originalEvent` STRING ) Regards Hans