文章 2024-08-19 来自:开发者社区

实时计算 Flink版产品使用问题之使用StarRocks作为Lookup Join的表是否合适

问题一:请教一下Flink lookup join的表使用starrocks表合适吗? 请教一下Flink lookup join的表使用starrocks表合适吗? 参考答案: Flink 中的 lookup join 是一种特殊的 join 操作,用于将流数据与外部系统(如数据库、键值存储或搜索引擎)中的静态或缓慢变化的数据进行关联。在使用 loo...

实时计算 Flink版产品使用问题之使用StarRocks作为Lookup Join的表是否合适
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之任务无法实时同步MySQL到StarRocks中修改的数据,是什么原因

问题一:Flink CDC里mysql8 然后不是默认开始了binlog吗? Flink CDC里我用的mysql8 然后不是默认开始了binlog吗。然后我运行github上面的demo 并且设置了 startupOptions 但是控制台还是没有输出数据这是怎么回事? 参考答案: 是binlog生成日志的问题。 关于本问...

实时计算 Flink版产品使用问题之任务无法实时同步MySQL到StarRocks中修改的数据,是什么原因
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之如何对starrocks进行分桶

问题一:Flink CDC里如何把这个新的sqlStatment返回出去? Flink CDC里如何把这个新的sqlStatment返回出去? 参考答案: 在Flink CDC中,你可以通过以下步骤...

实时计算 Flink版产品使用问题之如何对starrocks进行分桶
文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之整库从mysql同步到StarRocks里面,首次全量是否会对mysql造成大量资源消耗,导致影响业务服务

问题一:有用springboot框架开发flink任务的朋友吗? 有用springboot框架开发flink任务的朋友吗? 参考答案: 关于Spring Boot框架开发Flink任务,是可以的。您可以将Flink应用以微服务的方式整合进Spring Boot项目中,利用Spring Boot的便利性进行资源管理和服务部署,同时结合Flink提供的Ja...

实时计算 Flink版产品使用问题之整库从mysql同步到StarRocks里面,首次全量是否会对mysql造成大量资源消耗,导致影响业务服务
文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之在进行整库同步MySQL数据到StarRocks时,遇到全量数据可以同步,但增量数据无法同步,是什么导致的

问题一:flink有什么办法可以加快同步速度吗? 我用flinkSql清洗 测试环境一个数据,join 8个表,8万条数据,为什么平均每秒才同步了5,6条数据吗?有什么办法可以加快同步速度吗? ...

实时计算 Flink版产品使用问题之在进行整库同步MySQL数据到StarRocks时,遇到全量数据可以同步,但增量数据无法同步,是什么导致的
阿里云文档 2024-06-04

Flink产品公告(2022年及之前)

本文为您介绍实时计算Flink版2022年及之前产品公告,包括平台升级、API版本升级等。

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

实时计算 Flink版产品使用合集之从MySQL到StarRocks的操作步骤是怎样的

问题一:在Flink CDC中, Flink 1.13.6 的文件系统 checkpoint 模式下? 在Flink CDC中, Flink 1.13.6 的文件系统 checkpoint 模式下,同步记录增加会使 chk-x 目录内的 uuid 格式文件变大,该文件保存了同步的数据记录。尽管数据已同步至数据库,全量同步记录仍存于内存并在ck时持久化,这可能导致taskmanager内存...

实时计算 Flink版产品使用合集之从MySQL到StarRocks的操作步骤是怎样的
文章 2024-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之监控 MySQL 数据写入到 StarRocks 中,在初始化成功后,但无法监控到插入的数据是什么导致的

问题一:Flink CDC我向mysql中插入数据成功,但是flinkcdc监控不到插入的数据呢? Flink CDC使用flinkcdc监控mysql写入到starrocks中,初始化成功之后,我向mysql中插入数据成功,但是flinkcdc监控不到插入的数据呢?用的多并行度? ...

实时计算 Flink版产品使用合集之监控 MySQL 数据写入到 StarRocks 中,在初始化成功后,但无法监控到插入的数据是什么导致的
文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之怎样导数据使starrocks支持主键模型delete的配置

问题一:Flink CDC-sql怎样导数据使starrocks支持主键模型delete的配置吗? Flink CDC-sql怎样导数据使starrocks支持主键模型delete的配置吗?目前只能更新和插入,但是删除不行 参考回答: 有虚拟列吧 关于本问题的更多回答可点击原文查看:https://developer.aliyun.c...

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

实时计算 Flink版产品使用合集之读取kafka数据然后入库到starrocks,出现未知问题如何解决

问题一:我刚刚看了一下Flink文档,好像没有哪里说支持动态topic,所以是不支持? 我刚刚看了一下Flink文档,好像没有哪里说支持动态topic,所以是不支持? 参考回答: 支持的,根据正则来匹配的,new FlinkKafkaConsume时,参数可以是正则匹配 关于本问题的更多回答可点击原文查看:https://develo...

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

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