Flink SQL一个Job使用多个Catalog的例子
大家好。 我没有在官网找到个Job使用多个Catalog的例子。 我想在一个Job里使用普通的Catalog注册个Kafka Source然后，将数据发送Iceberg Sink表。这个Sink表 注册在另一个Iceberg + Hive 的Catalog 中。 注册代码如下。 CREATE CAT...
在 Flink SQL 里，Catalog是做什么用的？
在 Flink SQL 里，Catalog是做什么用的？
Flink SQL 中Catalog的作用是什么？
Flink SQL 中Catalog的作用是什么？
为啥我使用了hive catalog之后 SQL语句执行报错，不支持查询proctime#Flink
为啥我使用了hive catalog之后 SQL语句执行报错，不支持查询proctime 去掉hive catalog 就不报错 可以正常查询 #Flink
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
产品推荐
社区圈子
最佳实践
