Apache Flink разрешает таблицу ⇐ JAVA

[Anonymous]

Попробуйте мое приложение API API Flink Table, чтобы слить события Kafka в таблицу айсберга: < /p>
Я пытаюсь создать ресурсы БД, используя Pure Flink Java API https://gist.github.com/kameshsampath/0 ... -java-l167, когда я пытаюсь создать таблицу, которую он дает мне следующую ошибку:

Код: Выделить всё

21:31:41,939 ERROR dev.kameshs.demos.flink.iceberg                              [] - Error running job
java.lang.IllegalArgumentException: table should be resolved
at [org.apache.iceberg.relocated.com](http://org.apache.iceberg.relocated.com).google.common.base.Preconditions.checkArgument(Preconditions.java:143) ~[iceberg-flink-runtime-1.20-1.7.1.jar:?]
at org.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/:?]

Любая подсказка/указатель/Пример, как это исправить?
Спасибо.

Подробнее здесь: https://stackoverflow.com/questions/793 ... ving-table