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]...
>>
>>
>> 请问如何解决，谢谢
