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

为什么flink光从kafka接收数据直接print,内存都能涨几个G啊?

为什么flink光从kafka接收数据直接print,内存都能涨几个G啊?

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

Flink这样传参的话,java代码中是用args[0] 接收吗?

Flink这样传参的话,java代码中是用args[0] 接收吗?

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

flink cdc 写代码的方式 接收数据-map操作-sink到表 是导入那个Maven依赖啊?

flink cdc 写代码的方式 接收数据-map操作-sink到表 是导入那个Maven依赖啊?

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

实时计算 Flink版操作报错合集之udf是怎么定义接收和返回的数据类型的

问题一:"flink cdc同步mysql数据失败,查了一下是连接中断,网络问题等等,不知道如何解决? "flink cdc同步mysql数据失败,查了一下是连接中断,网络问题等等,不知道如何解决? 参考回答: cdc是增量同步,连接超时了,查看一下网络环境吧 。 关于本问题的更多回答可点击原文查看:https://developer.aliy...

实时计算 Flink版操作报错合集之udf是怎么定义接收和返回的数据类型的
问答 2024-06-12 来自:开发者社区

Flink算子接收到Barrier会如何处理

Flink算子接收到Barrier会如何处理

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

Flink的TIMESTAMP类型怎么接收系统时间

Flink的TIMESTAMP类型怎么接收系统时间

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

实时计算 Flink版产品使用合集之已经处理了大量数据,但无法接收到新的数据,是什么原因

问题一:Flink CDC这里接收不到,已经跑了1.4亿数据了,之后有数据来也接受不到了? Flink CDC这看着是有数据进来的,这里接收不到,已经跑了1.4亿数据了,之后有数据来也接受不到了? 参考回答...

实时计算 Flink版产品使用合集之已经处理了大量数据,但无法接收到新的数据,是什么原因
问答 2024-04-11 来自:开发者社区

Flink中udf是怎么定义接收和返回的数据类型的呢?

Flink中udf是怎么定义接收和返回的数据类型的呢?比如我这边的A字段类型是Array,其元素类型是JSONObject。我希望返回的类型是JSONObject。我这边报错数据类型不合法?

问答 2024-01-18 来自:开发者社区

Flink CDC里如果接收到的ddl 没有在source指定的表中异常的设计逻辑是有什么考虑么?

Flink CDC里SchemaManager的applySchemaChange方法如果接收到的ddl 没有在source指定的表中,会抛异常,这一块的设计逻辑是有什么考虑么?例如指定10张表,但数据库其它表是也会产生schema变更的,这种情况就会报错了是为什么?

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

Flink CDC这里接收不到,已经跑了1.4亿数据了,之后有数据来也接受不到了?

Flink CDC这看着是有数据进来的,这里接收不到,已经跑了1.4亿数据了,之后有数据来也接受不到了?

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

产品推荐

实时计算 Flink

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

+关注