栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Flink 1.11集成Iceberg 0.12.1 报错a DynamicTableSource with SupportsFilterPushDown ability is not support

Flink 1.11集成Iceberg 0.12.1 报错a DynamicTableSource with SupportsFilterPushDown ability is not support

如题,从Iceberg 0.11.1 升级到0.12.1后,用Flink尝试读取Iceberg表时报错如下

Exception in thread "main" java.lang.UnsupportedOperationException: Currently, a DynamicTableSource with SupportsFilterPushDown ability is not supported.
	at org.apache.flink.table.planner.plan.schema.CatalogSourceTable.$anonfun$validateTableSource$1(CatalogSourceTable.scala:211)
	at org.apache.flink.table.planner.plan.schema.CatalogSourceTable.$anonfun$validateTableSource$1$adapted(CatalogSourceTable.scala:208)
	at scala.collection.immutable.List.foreach(List.scala:392)
	...

怀疑是版本问题。。。从阿里云上发现了一个问答ScanTableSource 为什么不支持SupportsFilterPushDown的问题?
在此升级到Flink 1.12.1后问题解决。

相关参考
https://nightlies.apache.org/flink/flink-docs-release-1.14/release-notes/flink-1.12/
https://iceberg.apache.org/#flink/,发现Iceberg官网最近都没更新?

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/728873.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号