问答 2022-09-29 来自:开发者社区

聚合的统计数据用flink写入mysql ,那数据5s更新后 是删除前一条数据在写入吗

聚合的统计数据用flink写入mysql ,那数据5s更新后 是删除前一条数据在写入 还是直接写入新的一条, 如果直接写入的话 那旧的那条数据 不管么?

问答 2022-09-15 来自:开发者社区

维表关联更新的操作可以通过flink sql来做吗

维表关联更新的操作可以通过flink sql来做吗

问答 2022-09-06 来自:开发者社区

flink,我更新了代码, 重新启动任务,会从头同步数据么

flink,我更新了代码, 重新启动任务,会从头同步数据么

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

请问大家遇到过 postgres cdc 查询不到更新吗,我在 flink sql 执行了一个查询

请问大家遇到过 postgres cdc 查询不到更新吗,我在 flink sql 执行了一个查询 ,然后在业务数据库更新数据,但是 postgres cdc 查不到更新, 只有重新执行查询才能看到更新的数据。。。

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

flink有办法过滤某些列的更新吗?而且更新的语句不要传到下游,能做到吗?

flink有办法过滤某些列的更新吗?而且更新的语句不要传到下游,能做到吗?

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

flink 1.15.1版本,cdc可以选择什么版本?这个应该是cdc的官网还没把1.15的更新上去

flink 1.15.1版本,cdc可以选择什么版本?这个应该是cdc的官网还没把1.15的更新上去

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

大佬们,我flink 采用 upsert-kafka作为连接器建表(t1),数据中具有相同更新时间的

大佬们,我flink 采用 upsert-kafka作为连接器建表(t1),数据中具有相同更新时间的多条数据,查询t1表,数据取的是哪条呢

问答 2022-07-29 来自:开发者社区

问个问题,flink 运行过程中,我能更新lib 下cdc的库不,就是还有任务再正常运行我能删除fl

问个问题,flink 运行过程中,我能更新lib 下cdc的库不,就是还有任务再正常运行我能删除flink lib下的老版本cdc,然后上传个新版本的cdc,让新起的任务用新版本

问答 2022-07-22 来自:开发者社区

flink-cdc读取mysql的增量如果要保证顺序性(就是后更新的不会先处理)是不是flink的j

flink-cdc读取mysql的增量如果要保证顺序性(就是后更新的不会先处理)是不是flink的job并行度就得是1啊,那这样的话如何提高高吞吐呢?

问答 2022-07-20 来自:开发者社区

flink同步hologress到hologress 流任务,维表改动后 ,没办法更新到主表。这个问

flink同步hologress到hologress 流任务,维表改动后 ,没办法更新到主表。这个问题该怎么解决。

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

产品推荐

阿里云实时计算Flink

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

+关注