阿里云文档 2025-03-26

如何使用Flink处理表格存储数据

本文为您介绍如何使用Flink计算表格存储(Tablestore)的数据,表格存储中的数据表或时序表均可作为实时计算Flink的源表或结果表进行使用。

阿里云文档 2025-02-19

使用Tablestore+Flink搭建高性能实时交易统计系统

本文为您介绍使用表格存储和Flink实现交易数据实时统计的样例场景、架构设计和实现方案。

问答 2025-02-17 来自:开发者社区

flink cdc 3.1读取数据报错

flink 版本:1.16.2flink cdc 版本 3.0.1数据库:sqlserver 2019 使用table api 通过cdc 捕获数据时直接提示以下报错,这个报错是因为 我少了什么配置吗 2025-02-17 18:17:48,787 ERROR SplitFetcherManager:129 - Received uncaught exception.java.lang.Runt....

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

请教下,flink 实时采集mysql 数据报错,有遇到的吗?

请教下,flink 实时采集mysql 数据报错,有遇到的吗?

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

在Flink CDC中,用pipeline 连接器 同步mysql数据到kafka报错了,缺少什么?

在Flink CDC中,用 pipeline 连接器 同步mysql数据到kafka报错了,是缺少什么依赖了吗?

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

flink mysql cdc 读取数据报错,cdc无法继续读取数据,如何解决?

flink mysql cdc 读取数据报错,cdc无法继续读取数据,如何解决?io.debezium.connector.mysql.MySqlStreamingChangeEventSource [] - Stopped reading binlog after 0 events, no new offset was recorded

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

Flink1.18.1 CDC Mysql数据到Doris报错

Flink1.18.1+flink-sql-connector-mysql-cdc-3.0.1.jar 同步Mysql数据到Doris中,数据能全部同步到Doris中,只是过一长段时间后 任务会报错,请问是什么原因?如果是connector包版本问题,那么请问配套的版本号又是多少?具体错误如下:2024-07-16 18:19:22java.lang.RuntimeException: One ....

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

在Flink CDC中同步Mysql数据,数据能全部同步到目标,只是过一段时间后 任务会报错为什么?

在Flink CDC中同步Mysql数据,数据能全部同步到目标,只是过一段时间后 任务会报错,请问是什么原因?请参考图片:

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

在Flink CDC中明明有创建如下,但是使用同步消费kafka中数据的时候,会显示报错?

在Flink CDC中明明有创建 Topic :tidb_tmp_sync_cdc 但是使用kafka-sync-table同步消费kafka中数据的时候,显示Could not get metadata from server?请参考图片:

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

请教下flink 作业把数据写入holo 报错是这个,原因是什么呢?

请教下flink 作业把数据写入holo 报错是这个,原因是什么呢?com.alibaba.hologres.client.exception.HoloClientException: [UNKNOW:null]com.alibaba.hologres.client.exception.HoloClientException: [100分]The connection attempt faile....

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

产品推荐

实时计算 Flink

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

+关注