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

flink cdc sql 可以拿到数据的rowkind 信息吗?

flink cdc sql 可以拿到数据的rowkind 信息吗?

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

Flink 我在sql cli执行连接kafka建表sql(该kafka接收csv数据),然后有一条

Flink 我在sql cli执行连接kafka建表sql(该kafka接收csv数据),然后有一条数据造的不符合字段格式,导致报错,然后该flink作业就无法继续running了,请问该如何处理呢?

问答 2022-11-27 来自:开发者社区

请教个问题,通过flink sql能获取到某条数据update之前跟之后的状态吗?类似datastr

请教个问题,通过flink sql能获取到某条数据update之前跟之后的状态吗?类似datastream api里面json字符串的before跟after

问答 2022-11-27 来自:开发者社区

flink刚启动时通过sql创建任务时数据能复制到es,然后mongo里的数据就没了,再添加es也不

flink刚启动时通过sql创建任务时数据能复制到es,然后mongo里的数据就没了,再添加es也不同步cdc模拟一个mongo节点,是不是应该通过rs.status能查以呢?我查着还是一个主节点,没有子节点,是不是监听有问题啊

问答 2022-11-23 来自:开发者社区

我想问一下flink sql 如何读取一个小时之前的一条数据

给位大佬 有没有好的处理方式

问答 2022-11-21 来自:开发者社区

Flink SQL读取Kafka数据并写入 Kafka另外一个主题,为何总是持续重启?

Flink SQL读取Kafka数据并写入 Kafka另外一个主题,为何总是持续重启?

问答 2022-11-13 来自:开发者社区

各位大佬,请教一下,如果在flink cdc sql客户端 使用SQL查询表,怎么能记录原系统的数据

各位大佬,请教一下,如果在flink cdc sql客户端 使用SQL查询表,怎么能记录原系统的数据是变更还是删除操作状态及时间呢?

问答 2022-11-13 来自:开发者社区

jdbc_2.12-1.14.4 sink支持回撤流吗?似乎flink sql中-D的数据并不能执行

jdbc_2.12-1.14.4 sink支持回撤流吗?似乎flink sql中-D的数据并不能执行

问答 2022-11-05 来自:开发者社区

请教大佬们一个问题,flink sql cdc 怎么样可以做部分数据的同步,有部分数据是快照记录数据

请教大佬们一个问题,flink sql cdc 怎么样可以做部分数据的同步,有部分数据是快照记录数据不更新呢?

问答 2022-11-05 来自:开发者社区

,jdbc sink支持回撤流吗?似乎flink sql中-D的数据并不能执行删除的mysql的对应

,jdbc sink支持回撤流吗?似乎flink sql中-D的数据并不能执行删除的mysql的对应数据

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

产品推荐

数据库

分享数据库前沿,解构实战干货,推动数据库技术变革

+关注
AI助理

你好,我是AI助理

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