George Leonard
10/16/2025, 11:46 AMFlink SQL> CREATE CATALOG kafka_catalog WITH (
> 'type' = 'hive',
> 'hive-conf-dir' = './conf/'
> );
[INFO] Execute statement succeeded.
Flink SQL> use catalog kafka_catalog;
>
[INFO] Execute statement succeeded.
Flink SQL> CREATE DATABASE IF NOT EXISTS kafka_catalog.inbound;
>
[INFO] Execute statement succeeded.
Flink SQL> CREATE DATABASE IF NOT EXISTS kafka_catalog.outbound;
>
[INFO] Execute statement succeeded.
Flink SQL> CREATE CATALOG postgres_catalog WITH (
> 'type' = 'hive',
> 'hive-conf-dir' = './conf/'
> );
[INFO] Execute statement succeeded.
Flink SQL> use catalog kafka_catalog;
[INFO] Execute statement succeeded.
Flink SQL> show databases;
+---------------+
| database name |
+---------------+
| default |
| inbound |
| outbound |
+---------------+
3 rows in set
Flink SQL> use catalog postgres_catalog;
[INFO] Execute statement succeeded.
Flink SQL> show databases;
+---------------+
| database name |
+---------------+
| default |
| inbound |
| outbound |
+---------------+
3 rows in set
Flink SQL> use catalog kafka_catalog;
[INFO] Execute statement succeeded.
Flink SQL> create database test;
[INFO] Execute statement succeeded.
Flink SQL> use catalog postgres_catalog;
[INFO] Execute statement succeeded.
Flink SQL> show databases;
+---------------+
| database name |
+---------------+
| default |
| inbound |
| outbound |
| test |
+---------------+Jaehyeon Kim
10/18/2025, 3:27 AMGeorge Leonard
10/18/2025, 10:33 AMGeorge Leonard
10/18/2025, 10:33 AM