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

[Anonymous]

Попробовать мое приложение API API Flink Table, чтобы дать события Kafka в таблицу айсберга:
Я пытаюсь создать ресурсы БД с использованием чистого явов https://gist.github.com /kameshsampath/0c4ad07b236bd38e999316598141b93e#file-ehicletelemetryprocessor-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