Re: Resolving Table using Java API

2025-01-30 Thread Pedro Mázala
In almost every case, the “table should be resolved” error from FlinkCatalog.createTable() means that the table identifier you are passing is either invalid, incomplete, or the catalog can’t figure out where the table is supposed to live. Most commonly, it’s because: The database (namespace) is emp

Resolving Table using Java API

2025-01-29 Thread Kamesh Sampath
I am on Apache Flink 1.20, trying to use pure Java SQL API to create a catalog and table in it. When I tried to do so I am getting the following error: ``` 21:31:41,939 ERROR dev.kameshs.demos.flink.iceberg [] - Error running job java.lang.IllegalArgumentException: t