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

Flink CDC中我依赖引入的2.4.1上没有这个方法,为什么?

"Flink CDC中我看github上边mongo sourcebuilder有startup.mode的方法,可是我依赖引入的2.4.1上没有这个方法,为什么?这是为啥,mongoconnector指定位点消费是2.5才支持的功能吗? com.ververica flink-connector-mongodb-cdc ...

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

请问flink1.15.2 + mysql-cdc2.3报错这个是需要添加什么依赖么?

"问题1:请问flink1.15.2 + mysql-cdc2.3报错这个是需要添加什么依赖么?问题2:需要加哪些?"

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

Flink CDC是非要等下一条数据发送,依赖下一条数据携带时间戳大于窗口的结束时间才会真正的触发?

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

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

升级到flink1.16以后发现使用mavn下载依赖的时候都没有你们有遇到是怎么处理的吗?

升级到flink1.16以后发现使用mavn下载依赖的时候都没有(现在使用的阿里云),你们有遇到是怎么处理的吗?

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

Flink CDC中这flink运行cdc的依赖包的挨个找吗?

Flink CDC中这flink运行cdc的依赖包的挨个找吗?有没有一整个都在的啊?

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

为什么FLINK运行的时候,会把这些依赖提交到 /user/ 这个目录可以改变吗? 大佬们

为什么FLINK运行的时候,会把这些依赖提交到 /user/datadev/.flink/application_1690893804631_0003 这个目录呢?这个目录可以改变吗? 大佬们

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

Flink CDC可以不捕获delete的操作的吗?好像mongodb不依赖debezium的喔,是

Flink CDC可以不捕获delete的操作的吗?好像mongodb不依赖debezium的喔,是不是mongo的就不能过滤delete了

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

Flink CDC这些依赖有问题吗?

Flink CDC这些依赖有问题吗?

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

想问下Flink,在新服务器上部署作业,但是服务器上不了网,怎么方便的把新环境依赖包都安装设置好?

想问下Flink,在新服务器上部署作业,但是服务器上不了网,怎么方便的把新环境依赖包都安装设置好?

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

Flink CDC中2.2.1切换2.4.0,旧任务的存档点还能用吗,只升级版本依赖,不改逻辑。

Flink CDC中2.2.1切换2.4.0,旧任务的存档点还能用吗,只升级版本依赖,不改逻辑。

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

产品推荐

阿里云实时计算Flink

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

+关注