Hi, I want to make the tables created by Flink Table API/SQL durable and permanent. To achieve this, I am trying the following basic example using the JDBC Oracle connector. I have added both the Flink JDBC and Oracle JDBC drivers to the Flink lib directory. I am using the Flink SQL client to run the queries. While it successfully creates tables in the default-database, I don't see the actual tables in the Oracle database. Moreover, the tables created under the Flink default-database seem to exist only as long as the session is active.
What steps should I take to ensure that the in-memory tables I work with during my Flink job are permanently stored in the database? The documentation mentions using Catalogs and Connectors to persist in-memory tables to a database. I want to store my tables and data in Oracle DB. However, I noticed that Flink supports only Hive, PostgreSQL, and MySQL catalogs. Does this mean my data will reside in Oracle while the metadata about the tables can be stored only in a Hive, PostgreSQL, or MySQL metastore? The documentation on this topic seems to cover only basic concepts and lacks complete examples on how to achieve this. Any pointers or detailed guidance would be greatly appreciated. Thanks.
