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

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

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

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

在Flink CDC中写代码的方式还得我们自己维护 新增/扩容字段 这些ddl操作?

在Flink CDC中像pipline 这种方式是不是支持 我在源数据库中 新增/扩容字段,而写代码的方式还得我们自己维护 新增/扩容字段 这些ddl操作?

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

在Flink CDC中通过配置文件,字段数据类型tinyint映射成boolean,如何操作?

在Flink CDC中通过配置文件,进行mysql同步doris。字段数据类型tinyint映射成boolean,如何操作?

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

Flink内存调优怎么操作?

Flink内存调优怎么操作?

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

Flink有操作过restapi 上传jar和开启job的吗 ?

Flink有大佬操作过restapi 上传jar和开启job的吗 ?

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

Flink按照JAR作业快速入门 文档上面操作报错了,好像是没权限读文件,是有什么其他的改动么?

Flink按照JAR作业快速入门 文档上面操作报错了,好像是没权限读文件,是有什么其他的改动么?

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

Flink的cdc 除了数据同步 还可以进行数据清洗打宽的操作么 ?

Flink的cdc 除了数据同步 还可以进行数据清洗打宽的操作么 ?要不然数据的清洗 还要有另外的触发的源

文章 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版操作报错合集之运行mysql to doris pipeline时报错,该如何排查

问题一:Flink CDC里有一张表,从EARLIEST_OFFSET启动就报这个错是为什么? Flink CDC里有一张表,从EARLIEST_OFFSET启动就报这个错,但是从最新位置消费就可以,这个是binlog文件的问题么? ...

实时计算 Flink版操作报错合集之运行mysql to doris pipeline时报错,该如何排查

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

产品推荐

阿里云实时计算Flink

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

+关注