[
https://issues.apache.org/jira/browse/FLINK-23675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lihangfei updated FLINK-23675:
------------------------------
Description:
select count(clicknum) as num
from table(
cumulate(table KafkaSource, desctiptor(app_date),interval '1'minutes, interval
'10' minutes))
where clicknum <>'-99'
group by window_start,window_end
like this it will not work with the question Flink doesn't support individual
window table-valued function cumulate(time_col=[app_date],max_size=[10
min],step=[1 min]...
This error also occurs when I use ’not in‘
was:
select count(clicknum) as num
from table(
cumulate(table KafkaSource, desctiptor(app_date),interval '1'minutes, interval
'10' minutes))
where clicknum <>'-99'
group by window_start,window_end
报错 不支持cumulate函数，not in函数也不可以
Summary: flink1.13 cumulate unable use with compare function (was:
flink1.13 cumulate 函数不能和部分比较函数连用)
> flink1.13 cumulate unable use with compare function
> ---------------------------------------------------
>
> Key: FLINK-23675
> URL: https://issues.apache.org/jira/browse/FLINK-23675
> Project: Flink
> Issue Type: Bug
> Components: chinese-translation
> Affects Versions: 1.13.1
> Environment: flink 1.13.1
> Reporter: lihangfei
> Priority: Major
>
> select count(clicknum) as num
> from table(
> cumulate(table KafkaSource, desctiptor(app_date),interval '1'minutes,
> interval '10' minutes))
> where clicknum <>'-99'
> group by window_start,window_end
>
> like this it will not work with the question Flink doesn't support individual
> window table-valued function cumulate(time_col=[app_date],max_size=[10
> min],step=[1 min]...
> This error also occurs when I use ’not in‘
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
