各位老师好,以下是我的代码:
| Table midTable = tableEnv.fromDataStream(midStream, $("funcId"), $("funcIdDesc"), $("serverIp"), $("maxTime"), $("minTime"), $("pk"), $("eventTime").rowtime()); tableEnv.createTemporaryView("midTable1",midTable); Table resulTable = tableEnv.sqlQuery("SELECT funcId,funcIdDesc,serverIp,pk,min(maxTime-minTime) as minTime\n" + "FROM TABLE(CUMULATE(\n" + " TABLE midTable1"+ //" TABLE "+ midTable + " , DESCRIPTOR(eventTime)\n" + " , INTERVAL '60' SECOND\n" + " , INTERVAL '1' DAY))\n" + " GROUP BY window_start,window_end,funcId,funcIdDesc,serverIp,pk"); | 我在流转换为表的时候,定义了流中的字段eventTime为rowtime,但是在执行下面的sqlQuery语句的时候,还是报错:Rowtime timestamp is not defined. Please make sure that a proper TimestampAssigner is defined and the stream environment uses the EventTime time characteristic 想请教一下各位老师解决之法 | | 小昌同学 | | ccc0606fight...@163.com |