SQL source-阿里云

flink cdc sql将一个source，sink到pg和kafka，这种场景支持吗?

Flink sql 里面非binlog Source表，可以设置轮询时间吗？

Flink sql 里面非binlog Source表，可以设置轮询时间吗？想着从hologre里面的A表，间隔两分钟，使用flinksql加工下，再存入hologres的B表，定时调度时间间隔最小5分钟，想把时间间隔缩小到1-2分钟。比如想做出一个召回集，给用户做推荐用；最初想着，间隔1分钟差不多...

如何在 PolarDB-X 中优化慢 SQL

2 课时 |

113 人已学 |

加入学习

SQL完全自学手册

61 课时 |

3601 人已学 |

加入学习

SQL Server on Linux入门教程

14 课时 |

4329 人已学 |

加入学习

Flink CDC sql 版本，mongo connector 如何提升source的消费速率？

Flink CDC sql 版本，mongo connector 如何提升source的消费速率？【业务背景】有一批百亿级别的数据需要同步从mongo同步到doris，存量+增量都要同步，所以想使用CDC同步，但是发现速率太慢，目前QPS 2w，预计300亿要同步20天左右才能跑完。【当前 job ...

Flink CDC中flink-sql 连上了 oracle source，这是咋回事？

Flink CDC中flink-sql 连上了 oracle source，但是没数据展示出来，这是咋回事？

在Flink需要把source里某个字段加工下得到一个字段，sql该如何写？

在Flink需要把source里某个字段加工下得到一个字段，sql该如何写？source里定义了5个字段，sink里定义了6个字段，

OceanBase数据库中使用source命令导入sql会中断是怎么回事？

"OceanBase数据库中使用source命令导入sql会中断是怎么回事？并且中断后必须重启observer才可以，问题出在哪里？就是使用source导入sql 文件，文件大小100多兆，但是导入部分就中段了。"

flink sql mysql cdc 2.4现在支持source合并吗？就像这样？

flink sql mysql cdc 2.4现在支持source合并吗？就像这样？source为同一张表时自动合并，多个 Source 只需要读取一份 binlog 数据

flink sql里面有没有判断不在实时维表中的source数据的好方法？

flink sql里面有没有判断不在实时维表中的source数据的好方法？前提维表与流数据主键一致。正常SQL 一般是在条件里加where not exists （SELECT 1 WHERE A=B），但是看实时维表句法写死了，只能写JOIN tb1 FOR SYSTEM_TIME AS OF t...

问个小白问题：Flink SQL里，source读取kafka数据，然后根据orderId 统计总？

问个小白问题：Flink SQL里，source读取kafka数据，然后根据orderId 统计总量；我使用 SELECT COUNT(orderId) FROM source_table；的方式来计算总数；我的疑问点是，flink是如何处理这些source数据的，比如 kafka推过来 100W条...