问答 2024-03-19 来自:开发者社区

flink sql cdc里面加了一个条件,初次同步的时候,他是会先把所有符合条件的数据读出来吗?

flink sql cdc里面加了一个条件,初次同步的时候,他是会先把所有符合条件的数据读出来吗,我看好长时间一动不动,是这样我们表里面有一年的数据,现在我只想同步近三个月的数据,所以加了个时间条件,但是现在这个同步没有开始呢,一直卡着。我现在是在最后的insert里面加的select where create_time > 三个月前的时间 这样写会有啥问题吗?还是在创建表的时候,指定开始的...

文章 2024-02-25 来自:开发者社区

Flink报错问题之Sql往kafka表写聚合数据报错如何解决

问题一:Flink操作 kafka ,hive遇到kerberos过期 请问下 Flink操作 kafka ,hive遇到kerberos过期 有什么解决方法吗?*来自志愿者整理的flink邮件归档 参考答案: 遇到kerberos过期问题,应该是你使用的是ticket cache,而不是keytab文件做认证*来自志愿者整理的flink邮件归档 ...

文章 2024-02-25 来自:开发者社区

Flink sql 问题之主动使数据延时一段时间如何解决

问题一:Flink sql 主动使数据延时一段时间有什么方案 我们有这样一个场景,双流join,一个快流,一个慢流,想让快流等一段时间,目的是能提高join的命中率。 FLink sql有什么方案实现吗? 参考回答: 我们也遇到过类似场景。 如果你的数据里面有事件时间,可以写个udf来判断下,如果事件时间-当前时间 小于某个阈值,可以s...

文章 2024-02-24 来自:开发者社区

Flink SQL 问题之看不到数据如何解决

问题一:Flink如下报错怎么办? Flink-1.15.2 Standalone oracle-connector-2.3 8核 32G 16 Slots state.backend=rocksdb checkpointDir=file:///... savepointDir=file:///... Environment In Streaming Mode SQL 定义Source和Sink....

Flink SQL 问题之看不到数据如何解决
问答 2024-02-01 来自:开发者社区

Flink CDC里flink sql 维表 jdbc lookup join,如何更新结果数据呢?

Flink CDC里flink sql 维表 jdbc lookup join,当左表数据不更新时,维表变动,如何更新结果数据呢?

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

请教个问题,flink sql 维表 jdbc lookup join,如何更新结果数据呢?

请教个问题,flink sql 维表 jdbc lookup join,当左表数据不更新时,维表变动,如何更新结果数据呢?

问答 2024-01-25 来自:开发者社区

flink sql 如何往一个未定义列的表中写入数据?

flink sql支持创建没有定义schema的表,如create table test with ('connector'='print'); 那么如何往这种表中写入数据呢?当执行insert into select时总会报org.apache.flink.table.api.ValidationException: Column types of query result and sink ....

问答 2024-01-24 来自:开发者社区

Flink CDC里为啥我用flink sql从kafka订阅canaljson插入数据删除不了?

Flink CDC里我用flink sql从kafka订阅canaljson插入数据,如果这个数据插入后,重启任务,然后发送canaljson无法删除,不重启的话就可以,为什么?

问答 2024-01-24 来自:开发者社区

FLINK SQL ,如果源上 delete 掉数据了,目标端能 DELETE 掉吗?

FLINK SQL ,如果源上 delete 掉数据了,目标端能 DELETE 掉吗?

问答 2024-01-09 来自:开发者社区

请问下,flink cdc sql方式,当一条数据更新时,结果会输出1条数据还是2条数据?

请问下,flink cdc sql方式,当一条数据更新时,结果会输出1条数据(跟新后) 还是2条数据(更新前、更新后)?

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

产品推荐

数据库

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

+关注
AI助理

你好,我是AI助理

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

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问