阿里云文档 2025-02-19

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

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

阿里云文档 2025-02-06

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

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

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

在Flink CDC中如下报错这个是源端数据导致的吗?

在Flink CDC中如下报错这个是源端数据导致的吗?Caused by: io.debezium.DebeziumException: org.apache.kafka.connect.errors.SchemaBuilderException: Cannot create field because of field name duplication PsbcExJson

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

实时计算 Flink版操作报错合集之怎么向一个未定义列的表中写入数据

问题一:Flink有知道这个问题吗? Flink有大佬知道这个问题吗?在做过滤是一直包这个错,找不到原因。class org.apache.flink.api.java.tuple.Tuple2 cannot be cast to class A (org.apache.flink.api.java.tuple.Tuple2 and class A are in unnamed modu...

实时计算 Flink版操作报错合集之怎么向一个未定义列的表中写入数据
文章 2024-07-17 来自:开发者社区

实时计算 Flink版操作报错合集之从mysql读数据写到hive报错,是什么原因

问题一:Flink CDC里这个报错需要调整什么参数吗? Flink CDC里这个报错需要调整什么参数吗,mysql本身看连接数和连接是正常的 参考答案: 检查connection-size 是不是...

实时计算 Flink版操作报错合集之从mysql读数据写到hive报错,是什么原因
文章 2024-07-17 来自:开发者社区

实时计算 Flink版操作报错合集之Hadoop在将文件写入HDFS时,无法在所有指定的数据节点上进行复制,该如何解决

问题一:Flink CDC里flinkcdc写hudi的时候这个错误怎么弄? Flink CDC里flinkcdc写hudi的时候这个错误怎么弄? own Source) at org.apache.hadoop.hdfs.DF...

实时计算 Flink版操作报错合集之Hadoop在将文件写入HDFS时,无法在所有指定的数据节点上进行复制,该如何解决
文章 2024-07-17 来自:开发者社区

实时计算 Flink版操作报错合集之拉取全量数据时,如何解决Checkpoint失败并且报错为 "java.lang.OutOfMemoryError: Java heap space"

问题一:Flink CDC2.4的包都有,为啥还报找不到类? Flink CDC2.4的包都有,为啥还报找不到类?java.lang.NoClassDefFoundError: com/ververica/cdc/connectors/base/options/JdbcSourceOptions ...

实时计算 Flink版操作报错合集之拉取全量数据时,如何解决Checkpoint失败并且报错为
问答 2024-07-11 来自:开发者社区

换了一个库,重新创建同名表,改名字,都是这样,显示有这个表,Flink报错说数据请求失败,怎么处理?

换了一个库,重新创建同名表,改名字,都是这样,显示有这个表,Flink报错说数据请求失败,怎么处理?

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

实时计算 Flink版操作报错合集之从 PostgreSQL 读取数据并写入 Kafka 时,遇到 "initial slot snapshot too large" 的错误,该怎么办

问题一:Flink CDC中mysql cdc采集的时候,这个监控没有值 是为什么呢? Flink CDC中mysql cdc采集的时候,这个监控没有值 是为什么呢? 参考回答: 关于本问...

实时计算 Flink版操作报错合集之从 PostgreSQL 读取数据并写入 Kafka 时,遇到
文章 2024-06-17 来自:开发者社区

实时计算 Flink版操作报错合集之同步MySQL数据并EP(复杂事件处理)时,编译报错,如何解决

问题一:Flink同步mysql的数据, 然后做CEP处理,编译就报错,是不支持mysql吗? Flink同步mysql的数据, 然后做CEP处理,编译就报错,是不支持mysql吗? 参考回答: 您好,看报错信息是,Match recognition不支持消费由节点Tablesourcescan产生的更新和删除更改。参考https://help.aliyun.c...

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等