Oh,it's designed for unaligned checkpoint.
Thanks,Zhanghao.
-- Original --
From:
"Zhanghao Chen"
Unsubscribe
Hi,
As far as I know, the community currently has no plans to support custom
triggers on Flink SQL,
because it is difficult to describe triggers using SQL.
You can create a jira[1] for it and restart the discussion in dev maillist.
[1] https://issues.apache.org/jira/projects/FLINK
--
Hi,
Currently, Flink's windows are based on time (or a fixed number of
elements). I want to trigger window computation based on specific events
(marked within the data). In the DataStream API, this can be achieved using
GlobalWindow and custom triggers, but how can it be done in Flink SQL?
Additio
Hello everyone.
In fact, the problem was coming from FileSystem.get() :
###
val fs = FileSystem.get(hadoopConfig)
###
When you want to interact with S3, you need to add a first parameter, before
the hadoop config, to specify the filesystem.
Something like this :
###
val s3uri = URI.create("s3a:/
Hello,Community: Why doesn't flink store in flight buffers to local disks
when it checkpoints?
Thanks.
Hi Xuyang,
Thank you for the information regarding the bug fix.
I will proceed with the method of joining input_table and udtf first. Thank
you for the suggestion.
Best regards, Norihiro Fuke.
2024年7月15日(月) 10:43 Xuyang :
> Hi, this is a bug fixed in
> https://github.com/apache/flink/pull/2507
