table api定义rowtime未生效

Tue, 16 May 2023 18:28:20 -0700 

各位老师好，以下是我的代码：

| 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
想请教一下各位老师解决之法
| |
小昌同学
|
|
[email protected]
|

回复