回答情况：
提问时间：
问题标签：
按照flink官网，直接部署完，启动 sql客户端，已经可以通过sql完成cdc功能。比如当前最新的flink2.0.0 ，flink-cdc是3.0.4
浏览 68提问于2025-07-18
我正在使用Postgres作为源的Flink应用程序来读取某些配置数据，将其转换为数据流，然后将其与传入的实时数据流连接起来。但是，我的要求是使用CDC源本身中的联接条件从多个表中读取数据，然后将其转换为数据流。我们可以在源中编写自定义查询吗？
浏览 1提问于2022-04-07得票数 0
我有一个kafka队列，其中有多个cdc事件来自数据库。name":"maths", "teacher":"Foo", ...}Updates(比如电子邮件、电话、.)或课程信息(时间、教师、.)在任一表上发生的1次事件
我的问题是，我不知道如何存储和关联说的CDC在flink中有获得这种行为的方法吗？
浏览 2修改于2022-02-04得票数 0
与“卡夫卡”事件的来源，以丰富这一事件的关键与现有的cdc数据。kafka源(id，B，C) + cdc (id，D，E，F) =结果(id，B，C，D，E，F)进入kafka接收器(附加) ) WITH ( 'topic' = 'as-test-output-flink
浏览 2提问于2021-07-14得票数 1
例如，我有一个Flink表，如WITH ( 'scan.startup.mode' = 'xxx', Hive执行，显
浏览 6提问于2022-05-07得票数 0
为了丰富数据流，我们计划将MySQL (MemSQL)服务器连接到现有的flink流应用程序此外，我还发现了另一个名为Flink-CDC https:/
浏览 19提问于2022-02-07得票数 0
回答已采纳
根据https://github.com/ververica/flink-sql-CDC的说法，我正在尝试遵循flink cdc的例子。但是我不能让flink作业管理器上的web ui工作？我最终选择了localhost didn’t send any data.。到同一端口的REST API工作正常 你知道可能出了什么问题吗？
浏览 25提问于2021-09-14得票数 0
1回答
sql-client-dqfaults.yaml文件之后， catalogs: type: hive
hive-conf-dir: /cdcSLF4J: Found binding in [jar:file:/cdc/flink-1.12.0/lib/log4j-slf4j-impl-2.12.1.jar!Searching for '/cdc/flink</em
浏览 0修改于2021-01-20得票数 1
计划在flink列表状态中缓冲cdc事件，直到它们准备好被流。对于给定的键可以支持的最大列表大小是什么？
浏览 8提问于2022-05-27得票数 0
每次我运行简单的flink作业时，Iv都会出现这个错误 cdcEnv.setStateBackend(new FsStateBackend(ResourceUtil.getKey("checkpointUri") + "/flinkproperties));
浏览 2修改于2021-03-03得票数 2
我有一个在Spring应用程序中运行的Flink应用程序。应用程序无法在Flink集群中作为jar运行。我能够将应用程序作为一个jar运行在我的本地windows计算机(迷你集群)上。(StreamPlanEnvironment.java:53) at cdc.il.cdm.application.CdmApplication.run(CdmApplica
浏览 0修改于2019-07-02得票数 2
当我使用pyflink hive sql read data insert into es时，抛出以下异常:环境: flink 1.11.2 flink-sql-connector-hive-3.1.2tmp], fields=[driver_id, is_incremental, dt, bdi_feature_create_time]) (1/1) (98f4259c3d00fac9fc3482a4cdc8df3c:90) ~[flink-dist_2.11-1.11.2.jar:1.11.2]
at
浏览 338提问于2020-12-17得票数 0
我正在做一个flink CDC + iceberg的POC。我按照这个debezium教程将cdc发送到kafka - https://debezium.io/documentation/reference/1.4/tutorial.html。我的flink作业工作得很好，可以将数据写入hive表以进行插入。但是，当我向mysql表发起更新/删除查询时，我开始在flink作业中收到这个错误。Out) (3/4)] ERROR
浏览 474提问于2021-03-26得票数 1
回答已采纳
使用FLINK CDC，我能够从RDS获得我想要的数据，并使用JDBC库汇到MYSQL。我的目标是读取一个表，并使用下面的代码示例创建另外10个表，在一个作业中(基本上将一个巨大的表分成较小的表)。我面临的问题是，尽管在flink cdc中使用RocksDB作为状态后端和选项，如scan.incremental.snapshot.chunk.size、scan.snapshot.fetch.sizeTIMESTAMP(3),
浏览 30修改于2021-11-24得票数 0
我正在尝试使用flink的table API创建一个使用Debezium源函数的表，我在中找到了这些函数的一个实现，并在我的代码中像这样使用它们：我还按照文档中的描述添加了这个依赖项：
"com.alibaba.ververica" % "flink-sql-connector-postgres-cdc" % "1.1.0
浏览 6修改于2020-11-21得票数 0
我们使用flink从一些IoT传感器生成事件。每个传感器都可以用来产生不同类型的事件(如温度、湿度等)。一对多的比率(传感器->启用事件)。如何在flink最佳实践方面做得最好？据我所知，在我的例子中，我多次乘以数据流，尽管我随后过滤了结果。
浏览 4修改于2022-01-27得票数 1
我正在尝试使用docker构建一个maven项目，并在flink中提交一个生成的jar。但最终，还是有一些例外发生了。任何人都可以帮助我解决这个异常。=/opt/flink
ENTRYPOINT ["./bin/flink", "run", "-c", "c
浏览 59提问于2020-08-08得票数 0
原因: org.apache.flink.table.api.TableException: Match Recognize不支持由节点连接(joinType=InnerJoin，where=(id =STRING> , id STRING PRIMARY KEY> WITH (org.apache.flink.table.api.Tab
浏览 14修改于2022-07-20得票数 0
@ org.apache.flink:flink-scala_${scala.binary.version}:1.15.0, C:\Users\bk73027\Projects\FlinkDemo\flink\bk73027\Projects\FlinkDemo\flink-1.15.0\flink-connectors\flink-hadoop-compatibility\pom.xml, line 32\flink-1.15.0\flink-con
浏览 7修改于2022-06-24得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号