You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 李航飞 <te...@163.com> on 2021/08/11 03:40:56 UTC
cumulate 不能和比较函数连用
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]...
请问如何解决，谢谢
Re:Re:Re: cumulate 不能和比较函数连用
Posted by 李航飞 <te...@163.com>.
抱歉，sql语句是我手打的，没注意到，我确定和这个descriptor没关系。<br/>我去掉where条件就能正常运行，同时，我测试in，not in 函数的时候，会报同样的错误。
At 2021-08-11 13:51:16, "李航飞" <te...@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" <ts...@gmail.com> 写道：
>>Hi！
>>
>>descriptor 拼错了吧。我在本地没有复现这个问题，Flink 版本是多少呢？
>>
>>李航飞 <te...@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]...
>>>
>>>
>>> 请问如何解决，谢谢
Re:Re: cumulate 不能和比较函数连用
Posted by 李航飞 <te...@163.com>.
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" <ts...@gmail.com> 写道：
>Hi！
>
>descriptor 拼错了吧。我在本地没有复现这个问题，Flink 版本是多少呢？
>
>李航飞 <te...@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]...
>>
>>
>> 请问如何解决，谢谢
Re: cumulate 不能和比较函数连用
Posted by Caizhi Weng <ts...@gmail.com>.
Hi！
descriptor 拼错了吧。我在本地没有复现这个问题，Flink 版本是多少呢？
李航飞 <te...@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]...
>
>
> 请问如何解决，谢谢