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

在Flink CDC中,flink sql任务同步mysql数据时,可能是什么原因?

在Flink CDC中,flink sql任务同步mysql数据时,taskmanager日志中存在报错,但是任务没挂,全量数据也没同步到upsert-kafka中,请问大佬们可能是什么原因?

阿里云文档 2024-07-17

Flink SQL开发调优实践

说明实时计算Flink版控制台界面和功能可能会发生变化,具体请以实际控制台为准。

阿里云文档 2024-06-27

SQL作业大状态导致反压的调优方法

状态管理不仅影响应用的性能,还关系到系统的稳定性和资源的有效利用。如果状态管理不当,可能会导致性能下降、资源耗尽,甚至系统崩溃。本文为您介绍SQL作业大状态导致反压的调优原理与方法。

阿里云文档 2024-06-26

Flink SQL中Changelog事件乱序处理原理

本文围绕Flink SQL实时数据处理中的Changelog事件乱序问题,分析了Flink SQL中Changelog事件乱序问题的原因,并提供了解决方案以及处理Changelog事件乱序的建议。以帮助您更好地理解Changelog的概念和应用,更加高效地使用Flink SQL进行实时数据处理。

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

Flink SQL计算任务从checkpoint恢复流程是怎样的

Flink SQL计算任务从checkpoint恢复流程是怎样的

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

DTS源为SQL Server是否支持通过Flink SQL模式配置ETL任务

DTS源为SQL Server是否支持通过Flink SQL模式配置ETL任务

问答 2024-05-28 来自:开发者社区

flink sql 用doris作为source和sink 跑起任务后为什么不是流计算?

flink sql 用doris作为source和sink 跑起任务后为什么不是流计算?数据跑完任务就结束了

问答 2024-05-20 来自:开发者社区

我flink SQL 任务 +rockdbs,那我设置三分钟状态有效期 不会使得cp 状态减少吗 ?

我flink SQL 任务 +rockdbs,那我设置三分钟状态有效期 不会使得cp 状态减少吗 ?是不是目前flink底层没有支持这个功能?

问答 2024-05-20 来自:开发者社区

我这边flink sql任务设置了SET 请问怎么 还是全量读取数据呢?

我这边flink sql任务设置了SET 'table.exec.state.ttl' = '24h' 后,从savepoint恢复任务,请问怎么 还是全量读取数据呢? 去掉ttl设置后 从savepoint恢复 则执行正常

文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之将OceanBase的CDC数据导入到Flink SQL的任务的步骤是什么

问题一:Flink CDC将hive作为source表,为啥总是一提交就结束呢,有人碰到过么? Flink CDC将hive作为source表,为啥总是一提交就结束呢,有人碰到过么? 参考回答: Flink CDC将Hive作为source表,一提交就结束的问题可能有多种原因。首先,需要确认的是Flink作业的配置是否正确,例如是否正确指定了Flink...

实时计算 Flink版产品使用合集之将OceanBase的CDC数据导入到Flink SQL的任务的步骤是什么

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

产品推荐

阿里云实时计算Flink

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

+关注