文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之使用 left interval join 和 timestamp assigner 进行灰度切换,并发现在灰度完成后水印停滞不前如何解决

问题一:请问一下Flink,我进行双流join之后,为什么右表的数据没有了啊? 请问一下Flink,我进行双流join之后,为什么右表的数据没有了啊? 正常应该是有数据能匹配上的,是我有什么配置没有配吗?在sql里这个配置能更改吗? 参考回答: 超过了这个时间没数据更新,右边就会匹配不到,state有默认存储时间的.这个是不好的,state时间越长,状...

实时计算 Flink版产品使用合集之使用 left interval join 和 timestamp assigner 进行灰度切换,并发现在灰度完成后水印停滞不前如何解决
问答 2024-01-04 来自:开发者社区

如果使用flink sql的left join,右表出现部分关联不上的情况,应该怎么处理好?

请问下,如果使用flink sql的left join,右表出现部分关联不上的情况,应该怎么处理好一点哈?

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

flink sql 多个left join,开启mini batch后乱序,大家有什么解决方案么?

flink sql 多个left join,每个join都是不同的字段。开启mini batch后乱序,大家有什么解决方案么?

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

Flink CDC有时间帮忙看一下flink sql 多表left join 写入失败的问题嘛?

Flink CDC有时间帮忙看一下flink sql 多表left join 写入失败的问题嘛,总是报检查点写入失败?

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

Flink CDC2.4.1 flink1.14.6,sql left join一些表,这个咋解决?

Flink CDC2.4.1 flink1.14.6,sql left join一些表,非主键关键,会丢失delete同步,这个咋解决?

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

Flink CDC left join 5张表每张表都要监听数据变化,都用cdc 会有问题吗?

问题1:Flink CDC left join 5张表每张表都要监听数据变化,都用cdc 会有问题吗?问题2:那怎么办呢, left join的几个表的数据都要监听呀

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

Flink CDC left join 5张表,都要监听变化数据都用cdc 会有问题吗?

Flink CDC left join 5张表,都要监听变化数据都用cdc 会有问题吗?

问答 2023-08-16 来自:开发者社区

Flink CDC中我想用A left join B 怎么定义这个B表呢?

"Flink CDC中我想用A left join B ,A是个mysql-cdc数据流,B是个mysql外部表,A每次来一条数据就去查询下mysql数据库查找最新数据,要怎么定义这个B表呢?能否通过定义ddl的简单方式定义一个mysql表,实现每次都去查询最新数据而不是历史数据?"

问答 2023-07-26 来自:开发者社区

flink sql任务有三个mysql cdc 源表通过left join关联写入目标表,没更新?

flink sql任务有三个mysql cdc 源表通过left join关联写入目标表。过了半天之后,更新源表中的记录,发现目标表没更新。这是flink SQL不支持吗,还是要做什么特殊设置,或者使用什么语法?就是更新了where条件对应的记录,另外,大表join,是如何做实时记录匹配的,应该是需要流内存拦截吧,不然怎么做到实时匹配呢?假如关联的两张表的记录一个在最开始就来了,另一个迟了很久才....

问答 2023-07-26 来自:开发者社区

请问flink mysql cdc 双流left join后再入库在目标表c没有删除呢?

"请问flink mysql cdc 双流left join后再入库mysql,insert into c select from a left join b,源表a某些数据删了,在目标表c没有删除呢?三个表都设置了主键。请问怎么解决?测试删除trans_detail的数据,在结果表里没有被删除,没有left join的话,能同步删除。INSERT INTO tr_flow_base_info_....

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

产品推荐

实时计算 Flink

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

+关注