Hi All, I am new to flink, trying to create an Iceberg table using flink. The doc here says you can create an iceberg table managed by Hadoop catalog. However flink doesn't doucment

hadoop

or

rest

catalog aywhere, am I missing something? The reason I ask is because I get validation exception when trying to create hadoop

catalog.

Catalog options are:

'catalog-type'='hadoop'

'type'='iceberg'

'warehouse'='.abfs://....'

at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)

at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)

at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:98)

at org.apache.flink.client.deployment.application.DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:84)

... 4 more

Caused by: org.apache.flink.table.api.ValidationException: Unable to create catalog 'hadoop_catalog'.

Catalog options are:

'catalog-type'='hadoop'

'type'='iceberg'

I would recommend reaching out to Iceberg for this

@Martijn Visser sure! i'll post an update here for documentation once I have some clarity.