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

jar作业的方式,kafka作为source 是只要有消息投递 flink这边就会消费么?

jar作业的方式,kafka作为source 是只要有消息投递 flink这边就会消费么? 还是说要等待savepoint的刷新?

阿里云文档 2024-07-31

Source变更兼容性

本文为您介绍Source变更的可兼容性和不可兼容性详情。

阿里云文档 2024-07-10

SQL变更的其他兼容性限制

本文为您介绍变更SQL除Query、Source和Sink之外的其他限制。

问答 2023-06-05 来自:开发者社区

rabbitmq为source的情况下 如果反序列化失败,Flink会一直消费数据,一直错误下去,?

rabbitmq为source的情况下 如果反序列化失败,Flink会一直消费数据,一直错误下去,这个有参数可以配置吗 ?

问答 2023-05-01 来自:开发者社区

我发现如果一个source对应的collection没有数据变更,flink任务的checkpoin

我发现如果一个source对应的collection没有数据变更,flink任务的checkpoint会卡住。看源码感觉和这一段代码有关,这个continue感觉比较疑惑,我的理解等待完成后应该继续判断心跳,往下游发送心跳记录?

问答 2023-03-21 来自:开发者社区

请问有没人知道mysql-cdc里面把source注册到flink-table这一块的源码实现在哪?

请问有没人知道mysql-cdc里面把source注册到flink-table这一块的源码实现在哪?

问答 2022-12-20 来自:开发者社区

使用Flink-sql-cdc-mysql-2.1.1作为source,Flink-sql-cdc-

使用Flink-sql-cdc-mysql-2.1.1作为source,Flink-sql-cdc-tidb-2.2.0作为sink。想要做全增量一体化数据库同步,出现以下情况 :任务启动后会将数据库存量数据一次性导入,但是增量数据要过20分钟才会开始同步,这是什么原因呢?

问答 2022-09-22 来自:开发者社区

这种数据,怎么设置kafka source,才能让flink 继续消费?

源端脏数据(日期为1899年),debezium 解析完为负数(EFF_DATE:-2211696000000),这种数据,怎么设置kafka source,才能让flink 继续消费

问答 2021-11-17 来自:开发者社区

为什么要对Source API-Flink接口进行合并呢?

为什么要对Source API-Flink接口进行合并呢?

问答 2021-11-17 来自:开发者社区

Source API-Flink有几个接口?

Source API-Flink有几个接口?

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

产品推荐

实时计算 Flink

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

+关注