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

在Flink CDC中这种模式Kafka到mysql可以kakfa到doris不行,也不报错为什么?

在Flink CDC中这种模式Kafka到mysql可以,kakfa到doris不行,也不报错,数据进不了doris,为什么?请参考图片:

问答 2024-07-23 来自:开发者社区

Flink SQL 如何支持批模式?

Flink SQL 如何支持批模式?

文章 2024-07-16 来自:开发者社区

实时计算 Flink版操作报错合集之向远端flink提交cdc模式作业时,连接池中的连接超时,该如何处理

问题一:Flink用jdbc catalog连接postgresql时pg的schema里有横线该怎么处理? Flink用jdbc catalog连接postgresql时,pg的schema里有横线该怎么处理呢? ...

实时计算 Flink版操作报错合集之向远端flink提交cdc模式作业时,连接池中的连接超时,该如何处理
问答 2024-07-16 来自:开发者社区

Hologres 升级到2.1,会影响到Flink(使用的是cdc模式)计算嘛?

Hologres 升级到2.1,会影响到Flink(使用的是cdc模式)计算嘛?

文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之应用程序模式的作业如何从检查点保存的地方启动

问题一:Flink中appliction 模式怎么从 checkpoint 保存的地方 启动? Flink中appliction 模式怎么从 checkpoint 保存的地方 启动? 参考答案: 检查点是自动触发的,保存点是手动触发 关于本问题的更多回答可点击进行查看: https://developer.aliy...

实时计算 Flink版产品使用问题之应用程序模式的作业如何从检查点保存的地方启动
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之在online模式下增量抓取Oracle数据时,在archive_log切换时,出现数据丢失的情况,是什么原因

问题一:flink1.17.1 cdc 2.4.2也有这个问题呢? flink1.17.1 cdc 2.4.2也有这个问题呢?cdc拿到数据后,时间少了两个00 参考答案: 你可以自定义下debe...

实时计算 Flink版产品使用问题之在online模式下增量抓取Oracle数据时,在archive_log切换时,出现数据丢失的情况,是什么原因
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之在使用Flink on yarn模式进行内存资源调优时,如何进行优化

问题一:flink的applcation model模式和sql client可以一起用吗 flink的applcation model模式和sql client可以一起用吗,如何使用呢,如果不能使用,生产环境pre-job和session模式哪个模式会更好 参考答案: Apache Flink 支持多种部署模式,包括 Application Mode...

实时计算 Flink版产品使用问题之在使用Flink on yarn模式进行内存资源调优时,如何进行优化
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之在Flink on Yarn模式下,如何对job作业进行指标监控

问题一:flink1.14的网络缓存消胀机制,如果只是逻辑减少buffer的大小,这是不是会导致内存浪费? flink1.14的网络缓存消胀机制,如果只是逻辑减少buffer的大小,并物理的大小不变,这是不是会导致内存浪费?它是会改变所有的subtask的buffer大小吗?还是只有某个subtask? 参考答案: Flink 1.14的网络缓存消胀机...

实时计算 Flink版产品使用问题之在Flink on Yarn模式下,如何对job作业进行指标监控
问答 2024-07-15 来自:开发者社区

在Flink CDC中现在只支持session模式,后面会支持application等模式吗?

在Flink CDC中现在只支持session模式,每次提交还得修改flink-conf配置文件,后面会支持application等模式吗?

问答 2024-07-15 来自:开发者社区

Flink batch 模式下 实现多路多分片读 有示例么 ?

Flink batch 模式下 实现多路多分片读 有示例么 ?

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注