Flink catalog识别到的表 字段都重复了,导致sql 校验通过不了,该怎么解决?
Flink catalog识别到的表 字段都重复了,导致sql 校验通过不了,该怎么解决?写不进去了
Flink CDC jdbc catalog支持 oracle和SQL Server 有支持计划吗?
Flink CDC jdbc catalog支持 oracle和SQL Server 有支持计划吗?
flink sql不同通过jdbc连接hive吗?只能创建catalog加载整个库?那么不同hive
flink sql不同通过jdbc连接hive吗?只能创建catalog加载整个库?那么不同hive库,之间如何进行交互呢?
flink cdc数据写入iceberg(在flink sql上用的hive catalog)
flink cdc数据写入iceberg(在flink sql上用的hive catalog),然后在hive上直接查询该表无数据,用flink sql可以查到数据咋办? flink 1.13.1 iceberg 1.14.1 hive2.1.1
实时计算Flink版SQL是否能自动同步更新的字段到MySQL Catalog源表
实时计算Flink版SQL是否能自动同步更新的字段到MySQL Catalog源表
flink 1.15.2 sql cli 创建catalog报错这个
org.apache.flink.table.api.ValidationException: Unsupported options found for 'hive'
请问目前flink sql 支持postgresql Catalog吗?
请问目前flink sql 支持postgresql Catalog吗?
对Table & SQL 支持 JDBC Catalog的过程描述有?
对Table & SQL 支持 JDBC Catalog的过程描述有?
Flink SQL一个Job使用多个Catalog的例子
大家好。 我没有在官网找到个Job使用多个Catalog的例子。 我想在一个Job里使用普通的Catalog注册个Kafka Source然后,将数据发送Iceberg Sink表。这个Sink表 注册在另一个Iceberg + Hive 的Catalog 中。 注册代码如下。 CREATE CAT...
在 Flink SQL 里,Catalog是做什么用的?
在 Flink SQL 里,Catalog是做什么用的?
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。