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

flink-sql-connector-oracle-cdc-2.3.0 还没有url选项吗?看文档

flink-sql-connector-oracle-cdc-2.3.0 还没有url选项吗?看文档有这个选项?Flink SQL> select * from MONITOR_B__T_SYS_TIME_src;[ERROR] Could not execute SQL statement. Reason:org.apache.flink.util.SerializedThrowable:...

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

Flink CDC中我现在在跑官方文档上的例子,但是执行之后没有日志打印了,请问正常启动应该是怎样?

Flink CDC中我现在在跑官方文档上的例子,但是执行之后没有日志打印了,请问正常启动应该是怎样的? 中间对数据库进行了插入,但是也没有反应,使用的是DataStream API的例子,完整的信息提交在github的讨论中了,请路过的大佬帮忙看一下https://github.com/ververica/flink-cdc-connectors/discussions/2214

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

Flink CDC中刚才看了下文档,如果要做窗口聚合,这边就是取增量数据的ts时间+表名做开窗就行?

Flink CDC中刚才看了下文档,如果要做窗口聚合,这边就是取增量数据的ts时间+表名做开窗就行了是吗??我这边一共是有四张表

文章 2023-06-16 来自:开发者社区

使用 Flink 实时发现最热 Github 项目实验手册|Flink-Learning 实战营

作者|王洪顺(弘舜)  实验简介 通过 Flink 对 GitHub 的实时事件流进行分析,并通过报表直观展示,了解 GitHub 的最新热门趋势、特定仓库或者组织的活跃度。 体验此场景后,可以对 Flink SQL 基础能力和 Flink 实时处理特性有直观的初步体验。 实验资源 本场景使用到的实验资源和配置如下: 阿里云实...

使用 Flink 实时发现最热 Github 项目实验手册|Flink-Learning 实战营
问答 2023-06-11 来自:开发者社区

根据Flink CDC 社区文档示例 引入了flink-还需要引入其他的包吗 示例代码很?

根据Flink CDC 社区文档示例 引入了flink-connector-sqlserver-cdc 还需要引入其他的包吗 示例代码很多的类找不到?

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

大佬们, flink cdc 可以脱离flink单独使用吗?有相关文档介绍没有?恩内置了这个组件,为

大佬们, flink cdc 可以脱离flink单独使用吗?有相关文档介绍没有?恩内置了这个组件,为了做同步就引入flink有点重了,分布式也是依赖flink吧,理解得不对同仁帮忙修正一下

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

大佬 请问 Flink CDC中OracleSource 和这俩有什么区别吗?官方文档用的是

大佬 请问 Flink CDC中OracleSource 和 OracleIncrementalSource 这俩有什么区别吗?官方文档用的是SourceFunction,我用了后发现连接数太多,oracle扛不住了,后来看到也有OracleIncrementalSource,用了之后发现拉不到数据,也不知道咋回事

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

请教一下大佬,Flink CDC中使用文档给的 代码读取存量数据时,读到的数据是乱序的这是符合预期?

请教一下大佬,Flink CDC中使用文档给的 MongoDB CDC incremental connector 代码读取存量数据时,读到的数据是乱序的(不同于每个document插入的顺序),这是符合预期的吗,有什么方法能设置为顺序吗?

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

请问这个问题,有人遇到吗?flink1.16.1 cdc2.3版本的?看了这个文档,该配的,我好

问题1:请问这个问题,有人遇到吗?flink1.16.1 cdc2.3版本的?Could not execute SQL statement. Reason: org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'mysql-cdc' that implements...

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

Flink CDC中我看官方文档写的是只支持pojo和avro类型,那我应该怎么修改序列化类型,我?

Flink CDC中我看官方文档写的是只支持pojo和avro类型,那我应该怎么修改序列化类型,我使用的是sql-client提交的sql,我在官方文档没找到怎么设置?

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

产品推荐

阿里云实时计算Flink

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

+关注