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

截图里面的flinksql,为什么不用填mysql的地址 账号和密码,但可以部署运行?

截图里面的flinksql,为什么不用填mysql的地址 账号和密码,但可以部署运行?

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

在Flink CDC中flinksql写入到mysql的sink应该怎么写?

在Flink CDC中flinksql写入到mysql的sink应该怎么写?

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

flinksql 读取kafka数据 写入到mysql 按照主键更新 会不会导致数据乱序?

flinksql 读取kafka数据 写入到mysql 按照主键更新 如果上游并行度是3 再mysql ddl中设置sink.parallelism=2 会不会导致数据乱序啊 哪位大佬知道?还有就是 flinksql 有办法 实现keyby么。 控制按照哪个字段分区?

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

用flinkSQL请问这是不是在flink/lib目录下缺少了相关的mysql连接包?

用flinkSQL创建MySQL外表时报了个错,请问这是不是在flink/lib目录下缺少了相关的mysql连接包?想问下具体是咋解决这样的问题呢?

问答 2024-04-22 来自:开发者社区

Flink CDC里flinksql 一个并发写mysql 正常,2个并发消费任务都正常,为啥这样?

Flink CDC里flinksql 一个并发写mysql 正常,2个并发消费任务都正常,但是mysql 没有数据写入为啥?数据量是够的,消费任务都正常,就是没有数据写入,不知道数据怎么凭空消失了?

问答 2024-02-25 来自:开发者社区

FLinkSQL同步MySQL时,有遇到上游批量删除20w数据的场景吗?

FLinkSQL同步MySQL时,有遇到上游批量删除20w数据的场景吗,sink端一条条删除非常慢要怎么处理啊,2个小时都删不完?

问答 2023-12-24 来自:开发者社区

Flink CDC中flinksql采集mysql,这怎么解析到kafka,有方法解决吗?

Flink CDC中flinksql采集mysql,mysql字段类型是blob,数据是压缩后写入的,这怎么解析到kafka,有方法解决吗?

问答 2023-12-24 来自:开发者社区

Flink CDC中mysql单表数据同步到多个表,单纯使用flinksql能实现吗?

Flink CDC中mysql单表数据同步到多个表,单纯使用flinksql能实现吗,还是要通过table api?就是跑在一个任务里

阿里云文档 2023-11-21

如何新建FlinkSQL类型的公共节点

Flink SQL节点是流式节点,运行于Flink云计算资源之上,支持对ApsaraDB for RDS、Table Store、Hive、Kafka、Hbase、Phoenix、AnalyticDB MySQL和DataHub Service等类型的数据进行处理。本文介绍如何新建Flink SQL类型的公共节点。

文章 2023-11-20 来自:开发者社区

FlinkSQL 实时采集Kafka内容到MySQL(实战记录)

01 引言最近在做实时采集Kafka发布的内容到MySQL,本文记录一下关键的点,细节不再描述,希望能帮助到大家。02 实现2.1 添加依赖在工程,除了添加基础的Flink环境依赖,还需要添加flink-connector-kafka的依赖:<dependency> <groupId>org.apache.flink</groupId> <...

FlinkSQL 实时采集Kafka内容到MySQL(实战记录)

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

产品推荐

数据库

数据库领域前沿技术分享与交流

+关注
相关镜像
AI助理

你好,我是AI助理

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