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

Flink CDC对于oracle表,只抽取增量数据,这样的配置可以吗?

Flink CDC对于oracle表,只抽取增量数据,这样的配置可以吗?

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

Flink CDC如果使用增量快照的话,是不是需要配置一下或者依赖哪个包呢?

Flink CDC如果使用增量快照的话,是不是需要配置一下或者依赖哪个包呢?checkpointConfig.setSnapshotType(SnapshotType.INCREMENTAL) 这种配置方式无法实现

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

Flink CDC全量阶段开多并行度,增量阶段1并行度,可以动态配置吗?

Flink CDC全量阶段开多并行度,增量阶段1并行度,可以动态配置吗?

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

各位大佬,flink cdc读取pg只能读取到全量数据,读取不到增量数据,是需要哪个配置呢?

各位大佬,flink cdc读取pg只能读取到全量数据,读取不到增量数据,是需要哪个配置呢?

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

如何使用flink将增量数据写入配置单元

"我使用flink 1.6,我知道我可以使用自定义接收器和hive jdbc来编写hive,或者使用JDBCAppendTableSink,但它仍然使用jdbc。问题是hive jdbc不支持batchExecute方法。我认为它会很慢。然后我寻求另一种方式,我用writeAsText方法将数据集写入hdfs,然后从hdfs创建hive表。但是仍然存在一个问题:如何附加增量数据。 WriteMo....

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

产品推荐

阿里云实时计算Flink

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

+关注