抱歉,sql语句是我手打的,没注意到,我确定和这个descriptor没关系。<br/>我去掉where条件就能正常运行,同时,我测试in,not in 
函数的时候,会报同样的错误。
At 2021-08-11 13:51:16, "李航飞" <tex...@163.com> wrote:
>org.apache.flink.client.deployment.application.DetachedApplicationRunner [] - 
>Could not execute application: 
><br/>org.apache.flink.client.program.ProgramInvocationException: The main 
>method caused an error: Currently Flink doesn't support individual window 
>table-valued function CUMULATE(time_col=[ts], max_size=[10 min], step=[1 
>min]).<br/> Please use window table-valued function with aggregate together 
>using window_start and window_end as group keys.<br/>    at 
>org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
> ~[flink-clients_2.12-1.13.1.jar:1.13.1]<br/>        at 
>org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
> ~[flink-clients_2.12-1.13.1.jar:1.13.1]<br/>     at 
>org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114) 
>~[flink-clients_2.12-1.13.1.jar:1.13.1]<br/>        at 
>org.apache.flink.client.deployment.application.DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:84)
> ~
>在 2021-08-11 12:44:38,"Caizhi Weng" <tsreape...@gmail.com> 写道:
>>Hi!
>>
>>descriptor 拼错了吧。我在本地没有复现这个问题,Flink 版本是多少呢?
>>
>>李航飞 <tex...@163.com> 于2021年8月11日周三 上午11:41写道:
>>
>>> sql语句如下:
>>> select count(clicknum) as num
>>>
>>> from table(
>>>
>>> cumulate(table testTable, desctiptor(crtTime),interval '1'minutes,
>>> interval '10' minutes))
>>>
>>> where clicknum <>'-99'
>>>
>>> group by window_start,window_end
>>>
>>>
>>> 报错 信息:
>>> Flink doesn't support individual window table-valued function
>>> cumulate(time_col=[app_date],max_size=[10 min],step=[1 min]...
>>>
>>>
>>> 请问如何解决,谢谢

回复