NOTE
I can see my output table in MinIO, there is a metadata.json created.
I can also select from my source table.
Flink SQL> select * from c_cdcsource.demog.accountholders;
[INFO] Result retrieval cancelled.
Flink SQL> drop table c_iceberg.finflow.accountholders;
[ERROR] Could not execute SQL statement. Reason:
java.lang.AbstractMethodError: Receiver class org.apache.iceberg.flink.FlinkCreateTableOptions$$Lambda$1155/0x0000000601838000 does not define or inherit an implementation of the resolved method 'abstract void generate(
org.apache.iceberg.shaded.com.fasterxml.jackson.core.JsonGenerator)' of interface org.apache.iceberg.util.JsonUtil$ToJson.
Flink SQL> use catalog c_iceberg;
[INFO] Execute statement succeeded.
Flink SQL> use finflow;
[INFO] Execute statement succeeded.
Flink SQL> show tables;
+----------------+
| table name |
+----------------+
| accountholders |
+----------------+
1 row in set
Flink SQL> drop table accountholders;
[ERROR] Could not execute SQL statement. Reason:
java.lang.AbstractMethodError: Receiver class org.apache.iceberg.flink.FlinkCreateTableOptions$$Lambda$1155/0x0000000601838000 does not define or inherit an implementation of the resolved method 'abstract void generate(
org.apache.iceberg.shaded.com.fasterxml.jackson.core.JsonGenerator)' of interface org.apache.iceberg.util.JsonUtil$ToJson.