退订
| |
王新隆
|
|
albe...@163.com
|
Hi Hunk,
there is documentation about watermarking in FlinkSQL [1]. There is also a
FlinkSQL cookbook entry about watermarking [2]. Essentially, you define the
watermark strategy in your CREATE TABLE statement and specify the lateness
for a given event (not the period in which watermarks are
hello,all
如题，目前我对1.16的新功能比较感兴趣，想问一下flink1.16什么时候可以完成release？什么时候会有一个可用的官方docker镜像？
| |
谭家良
|
|
tanjl_w...@126.com
|
Hi dear engineers,
I have one question about watermark generating mechanism in Flink SQL. There
are two mechanisms called Periodic Watermarks and Punctuated Watermarks, I want
to use Periodic Watermarks with interval 5 seconds (meaning watermarks will be
generated every 5 seconds), how
不用 interval join 用普通的流 join 。时间只要不是 proctime 或者 eventtime 就行。
Zhiwen Sun
On Sat, Oct 15, 2022 at 9:46 AM 余列冰 wrote:
> Hi!
>
> 我在使用Deduplicate之后进行Interval Join出现问题。我使用的Flink版本是1.15
>
> 我希望使用Flink的Interval Join进行双流关联，并且我的第一个表需要去重。以下是我的示例代码。
> ```sql
> CREATE TEMPORARY TABLE `source` (
> id
Hi，退订发送任意内容至邮箱user-zh-unsubscr...@flink.apache.org 即可
TROY <13574806...@126.com> 于2022年10月17日周一 14:46写道：
> 退订
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2022-10-13 00:19:15，"陈鑫" 写道：
> >退订
> >
>
退订
在 2022-10-13 00:19:15，"陈鑫" 写道：
>退订
>
Hi,
基于事件时间的 first row 去重是可能会产生更新消息的, 所以在 interval join 还不支持更新输入时会报错,
当前一个可行的方式时考虑基于 proctime 进行 first row 去重 (这将不会输出更新消息)
Best,
Lincoln Lee
余列冰 于2022年10月15日周六 09:46写道：
> Hi!
>
> 我在使用Deduplicate之后进行Interval Join出现问题。我使用的Flink版本是1.15
>
> 我希望使用Flink的Interval
