flink cdc SQL 的相关内容

Flink CDC里sql 的cdc 只能读到什么就写入什么吗？

Flink SQL> insert into dc_ods_air_daily_city_air_data_airmaster_log select * from dc_ods_air_daily_city_air_data_airmaster;[ERROR] Could not execut...

flink cdc 可以在flink-sql cli里面使用吗？报错如下怎么办？

flink cdc 可以在flink-sql cli里面使用吗？报错如下怎么办？要用这个包吗？

如何在 PolarDB-X 中优化慢 SQL

2 课时 |

113 人已学 |

加入学习

SQL完全自学手册

61 课时 |

3601 人已学 |

加入学习

SQL Server on Linux入门教程

14 课时 |

4329 人已学 |

加入学习

Flink CDC里想问下flink sql里有什么有用的参数限制拉取大小吗？

Flink CDC里由于binlog日志太大我source tidb会内存溢出找的参数都没啥用想问下flink sql里有什么有用的参数限制拉取大小吗？

Flink CDC里pipeline方式是自动进行端到端的表结构变更，SQL方式就不支持了吧？

Flink CDC里pipeline方式是自动进行端到端的表结构变更，datastream方式需要手动处理，SQL方式就不支持了，对吧？

Flink CDC里sql server cdc使用的话，有什么注意事项吗？

Flink CDC里sql server cdc使用的话，有什么注意事项吗？为什么我这边全量同步以后不增量同步了啊？

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

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

Flink CDC里我用flink SQL 同步一张表到es。日志不动，没有报错怎么排查？

Flink CDC里我用flink SQL 同步一张表到es。 tasks 状态一直卡在 DEPLOYING日志到这里就不动了：2024-01-23 22:15:38,787 INFO com.ververica.cdc.connectors.mysql.source.assigners.MyS...

Flink CDC里flink sql clickhouse 有支持的连接器吗？

Flink CDC里flink sql 有啥内置函数可以这么做？

问题一：Flink CDC里flink sql 有啥内置函数可以将 51,51 变成 [51,52] 吗 split 不行，不是内置函数？问题二：有没有内置函数可以进行数组去重，或者数组对比，比如[51,51]跟[52] 对比返回 [51]啊？

Flink CDC 1.12版本引入了对SQL Server的支持

Flink CDC 1.12版本引入了对SQL Server的支持，包括SqlServerCatalog和SqlServerTable。在SqlServerCatalog中，你可以根据表名获取对应的字段和字段类型。要使用Flink CDC 1.12版本的SqlServerCatalog，你需要添加...