文章 2023-10-11 来自:开发者社区

Flink--8、时间语义、水位线(事件和窗口、水位线和窗口的工作原理、生产水位线、水位线的传递、迟到数据的处理)

                                                        &...

Flink--8、时间语义、水位线(事件和窗口、水位线和窗口的工作原理、生产水位线、水位线的传递、迟到数据的处理)
问答 2023-10-03 来自:开发者社区

Flink CDC如果我只要针对某个数据库,解析cdc的事件,然后同步到目标库吗?

Flink CDC如果我只要针对某个数据库,开发一个不那么通用的同步工具,是不是可以直接参考对应数据库的flink-cdc-connectors,解析cdc的事件,然后同步到目标库?想做个oracle到mongo的,实时同步,不依赖flink啥的?

问答 2023-09-28 来自:开发者社区

Flink 窗口事件时间触发器是增量触发吗?

Flink 窗口事件时间触发器是增量触发吗?还是触发的所有数据,我现在这里触发的数据有点乱序了?看着像增量触发的啊,看着像触发的全量,我用事件时间 大于等于水印过滤掉了?

问答 2023-09-20 来自:开发者社区

Flink CDC中mysql cdc启动模式的timestamp,这个时间戳是相对于那个事件?

Flink CDC中mysql cdc启动模式的timestamp,这个时间戳是相对于那个事件?是记录发生变化的时间吗?

问答 2023-09-07 来自:开发者社区

Flink CDC 能获取biglog的事件执行时间吗,我写入hive需要一个sql的操作时间?

Flink CDC 能获取biglog的事件执行时间吗,我写入hive需要一个sql的操作时间?这个是flink的处理时间吧

问答 2023-08-29 来自:开发者社区

有大佬知道Flink CDC postgresql cdc要怎么捕获ddl事件吗?

有大佬知道Flink CDC postgresql cdc要怎么捕获ddl事件吗?我用2.4.1版本,设置includeSchemaChanges为true不起作用,捕获不到ddl事件。

问答 2023-08-16 来自:开发者社区

Flink CDC中 事件时间的 时态表join是怎么个语法?

Flink CDC中 事件时间的 时态表join是怎么个语法?

问答 2023-08-15 来自:开发者社区

Flink CDC中我定义了事件时间的watermark为什么在界面上不显示?

"Flink CDC中我定义了事件时间的watermark为什么在界面上不显示?我用的flinksql 读kafka。时间字符串转了long作为watermark,我这个是因为时间戳提取的有问题?"

问答 2023-08-14 来自:开发者社区

各位老师好,我这边在使用Flink的事件时间窗口的时候,关于窗口触发的条件我有一点疑问想咨询一下?

问题1:各位老师好,我这边在使用Flink的事件时间窗口的时候,关于窗口触发的条件我有一点疑问想咨询一下各位老师我是开了一个2分钟的事件时间的窗口,但是等到两分钟后窗口并没有主动触发,等我后面再发一条数据的时候,窗口再进行了触发所以我想请问一下窗口的触发机制不是时间点嘛,而是非要等到下一条数据发送,依赖于下一条数据携带的时间戳大于窗口的结束时间,上一个窗口才会真正的触发嘛?请各位老师指导一下?问....

问答 2023-07-03 来自:开发者社区

Flink sql基于事件时间的窗口函数 没有新数据 最后一个窗口不触发怎么整?

Flink sql基于事件时间的窗口函数 没有新数据 最后一个窗口不触发怎么整?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注