[
https://issues.apache.org/jira/browse/FLINK-16868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711590#comment-17711590
]
Chalres Tan commented on FLINK-16868:
-------------------------------------
hi [~jark], I was looking around for a way to perform early emits in Flink SQL.
In response to your first comment, I tried to add these configurations to my
TableEnvironment and realized that they don’t work for window TVF.
{code:java}
Exception in thread "main" org.apache.flink.table.api.TableException:
Currently, window table function based aggregate doesn't support early-fire and
late-fire configuration 'table.exec.emit.early-fire.enabled' and
'table.exec.emit.late-fire.enabled'. {code}
Are you aware of any substitute for early emit that do work with window TVF?
> Table/SQL doesn't support custom trigger
> ----------------------------------------
>
> Key: FLINK-16868
> URL: https://issues.apache.org/jira/browse/FLINK-16868
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API, Table SQL / Runtime
> Reporter: Jimmy Wong
> Priority: Minor
> Labels: auto-deprioritized-major
>
> Table/SQL doesn't support custom trigger, such as CountTrigger,
> ContinuousEventTimeTrigger/ContinuousProcessingTimeTrigger. Do we has plans
> to make it?
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
