admin管理员组

文章数量:1418618

Trying my Flink Table API app to drain Kafka events into a Iceberg Table:

I am trying to create DB resources using pure Flink Java API , when I try to create the table it throws me the following error:

21:31:41,939 ERROR dev.kameshs.demos.flink.iceberg                              [] - Error running job
java.lang.IllegalArgumentException: table should be resolved
    at [.apache.iceberg.relocated]().googlemon.base.Preconditions.checkArgument(Preconditions.java:143) ~[iceberg-flink-runtime-1.20-1.7.1.jar:?]
    at .apache.iceberg.flink.FlinkCatalog.createTable(FlinkCatalog.java:394) ~[iceberg-flink-runtime-1.20-1.7.1.jar:?]
    at dev.kameshs.demos.flink.iceberg.VehicleTelemetryProcessor.lambda$main$0(VehicleTelemetryProcessor.java:167) ~[main/:?]
    at java.util.Optional.ifPresent(Optional.java:178) ~[?:?]
    at dev.kameshs.demos.flink.iceberg.VehicleTelemetryProcessor.main(VehicleTelemetryProcessor.java:106) [main/:?]

Any clue/pointer/example how to fix this?

Thank you.

本文标签： javaApache Flink Resolving TableStack Overflow

版权声明：本文标题：java - Apache Flink Resolving Table - Stack Overflow 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://www.betaflare.com/web/1745291072a2651797.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。